Class: Aerospike::BatchPolicy

Inherits:
Policy
  • Object
show all
Defined in:
lib/aerospike/policy/batch_policy.rb

Overview

Container object for batch policy command.

Direct Known Subclasses

QueryPolicy, ScanPolicy

Instance Attribute Summary collapse

Attributes inherited from Policy

#consistency_level, #max_retries, #priority, #sleep_between_retries, #timeout

Instance Method Summary collapse

Constructor Details

#initialize(opt = {}) ⇒ BatchPolicy

Returns a new instance of BatchPolicy.



26
27
28
29
30
31
32
33
34
 
# File 'lib/aerospike/policy/batch_policy.rb', line 26

def initialize(opt={})
  super(opt)

  @max_concurrent_nodes = opt[:max_concurrent_nodes] || 0
  @record_queue_size = opt[:record_queue_size] || 5000
  @wait_until_migrations_are_over = opt[:wait_until_migrations_are_over].nil? ? false : wait_until_migrations_are_over

  self
end

Instance Attribute Details

#max_concurrent_nodes ⇒ Object

Returns the value of attribute max_concurrent_nodes.



23
24
25
 
# File 'lib/aerospike/policy/batch_policy.rb', line 23

def max_concurrent_nodes
  @max_concurrent_nodes
end

#record_queue_size ⇒ Object

Returns the value of attribute record_queue_size.



23
24
25
 
# File 'lib/aerospike/policy/batch_policy.rb', line 23

def record_queue_size
  @record_queue_size
end

#wait_until_migrations_are_over ⇒ Object

Returns the value of attribute wait_until_migrations_are_over.



23
24
25
 
# File 'lib/aerospike/policy/batch_policy.rb', line 23

def wait_until_migrations_are_over
  @wait_until_migrations_are_over
end