[−][src]Struct aerospike::policy::QueryPolicy
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 Clone for QueryPolicy
[src]
fn clone(&self) -> QueryPolicy
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Default for QueryPolicy
[src]
fn default() -> QueryPolicy
[src]
impl Debug for QueryPolicy
[src]
Auto Trait Implementations
impl Send for QueryPolicy
impl Sync for QueryPolicy
impl Unpin for QueryPolicy
impl UnwindSafe for QueryPolicy
impl RefUnwindSafe for QueryPolicy
Blanket Implementations
impl<T> Policy for T where
T: PolicyLike,
[src]
T: PolicyLike,
fn priority(&Self) -> &Priority
[src]
fn consistency_level(&Self) -> &ConsistencyLevel
[src]
fn deadline(&Self) -> Option<Instant>
[src]
fn timeout(&Self) -> Option<Duration>
[src]
fn max_retries(&Self) -> Option<usize>
[src]
fn sleep_between_retries(&Self) -> Option<Duration>
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = !
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,