Module: CassandraModel::CompositeRecord

Defined in:
lib/cassandra_model/composite_record.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(klass) ⇒ Object 



3
4
5
 
# File 'lib/cassandra_model/composite_record.rb', line 3

def self.included(klass)
  klass.extend CompositeRecordStatic
end

Instance Method Details

#delete_async ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/cassandra_model/composite_record.rb', line 14

def delete_async
  futures = composite_rows.map { |record| record.internal_delete_async }

  futures << internal_delete_async
  Cassandra::Future.all(futures).then { self }
end

#save_async(options = {}) ⇒ Object 



7
8
9
10
11
12
 
# File 'lib/cassandra_model/composite_record.rb', line 7

def save_async(options = {})
  futures = composite_rows.map { |record| record.internal_save_async(options) }

  futures << internal_save_async(options)
  Cassandra::Future.all(futures).then { self }
end

#update_async(new_attributes) ⇒ Object 



21
22
23
24
25
26
 
# File 'lib/cassandra_model/composite_record.rb', line 21

def update_async(new_attributes)
  futures = composite_rows.map { |record| record.internal_update_async(new_attributes) }

  futures << internal_update_async(new_attributes)
  Cassandra::Future.all(futures).then { self }
end