Struct aerospike::policy::QueryPolicy

pub struct QueryPolicy {
    pub base_policy: BasePolicy,
    pub max_concurrent_nodes: usize,
    pub record_queue_size: usize,
    pub fail_on_cluster_change: bool,
    pub filter_expression: Option<FilterExpression>,
}

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.

filter_expression: Option<FilterExpression>

Optional Filter Expression

Implementations

impl QueryPolicy

pub fn new() -> Self

Create a new query policy instance with default parameters.

pub const fn filter_expression(&self) -> &Option<FilterExpression>

Get the current Filter Expression

Trait Implementations

impl Clone for QueryPolicy

fn clone(&self) -> QueryPolicy

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueryPolicy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for QueryPolicy

fn default() -> Self

Returns the “default value” for a type.