Class: Aerospike::QueryPolicy

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

Overview

Container object for query policy command.

Instance Attribute Summary collapse

Attributes inherited from Policy

#consistency_level, #fail_on_filtered_out, #max_retries, #predexp, #priority, #replica, #sleep_between_retries, #timeout, #use_compression

Instance Method Summary collapse

Constructor Details

#initialize(opt = {}) ⇒ QueryPolicy

Returns a new instance of QueryPolicy.



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/aerospike/policy/query_policy.rb', line 29

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

  @max_retries = 0

  # Indicates if bin data is retrieved. If false, only record digests (and
  # user keys if stored on the server) are retrieved.
  # Default is true.
  @include_bin_data = opt.fetch(:include_bin_data, true)

  # Number of records to place in queue before blocking. Records received
  # from multiple server nodes will be placed in a queue. A separate thread
  # consumes these records in parallel. If the queue is full, the producer
  # threads will block until records are consumed.
  # Default is 5000.
  @record_queue_size = opt[:record_queue_size] || 5000

  # Limit returned records per second (rps) rate for each server.
  # Will not apply rps limit if records_per_second is zero.
  # Currently only applicable to a query without a defined filter (scan).
  # Default is 0
  @records_per_second = opt[:records_per_second] || 0

  self
end

Instance Attribute Details

#include_bin_data ⇒ Object

Returns the value of attribute include_bin_data.



25
26
27
 
# File 'lib/aerospike/policy/query_policy.rb', line 25

def include_bin_data
  @include_bin_data
end

#record_queue_size ⇒ Object

Returns the value of attribute record_queue_size.



26
27
28
 
# File 'lib/aerospike/policy/query_policy.rb', line 26

def record_queue_size
  @record_queue_size
end

#records_per_second ⇒ Object

Returns the value of attribute records_per_second.



27
28
29
 
# File 'lib/aerospike/policy/query_policy.rb', line 27

def records_per_second
  @records_per_second
end