Struct aerospike::policy::QueryPolicy
[−]
[src]
pub struct QueryPolicy { pub base_policy: BasePolicy, pub max_concurrent_nodes: usize, pub record_queue_size: usize, pub fail_on_cluster_change: bool, }
QueryPolicy
encapsulates parameters for query operations.
Fields
base_policy: BasePolicy
Base policy instance
max_concurrent_nodes: usize
Maximum number of concurrent requests to server nodes at any point in time. If there are 16
nodes in the cluster and max_concurrent_nodes
is 8, then queries will be made to 8 nodes
in parallel. When a query completes, a new query will be issued until all 16 nodes have
been queried. Default (0) is to issue requests to all server nodes in parallel.
record_queue_size: usize
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.
fail_on_cluster_change: bool
Terminate query if cluster is in fluctuating state.
Methods
impl QueryPolicy
[src]
Trait Implementations
impl Debug for QueryPolicy
[src]
impl Clone for QueryPolicy
[src]
fn clone(&self) -> QueryPolicy
[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
impl Default for QueryPolicy
[src]
fn default() -> QueryPolicy
[src]
Returns the "default value" for a type. Read more