[−][src]Struct aerospike::ScanPolicy
ScanPolicy
encapsulates optional parameters used in scan operations.
Fields
base_policy: BasePolicy
Base policy instance
scan_percent: u8
Percent of data to scan. Valid integer range is 1 to 100. Default is 100.
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 scan requests will be made to 8
nodes in parallel. When a scan completes, a new scan request will be issued until all 16
nodes have been scanned. 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 scan if cluster is in fluctuating state.
socket_timeout: u32
Maximum time in milliseconds to wait when polling socket for availability prior to performing an operation on the socket on the server side. Zero means there is no socket timeout. Default: 10,000 ms.
Methods
impl ScanPolicy
[src]
Trait Implementations
impl Clone for ScanPolicy
[src]
fn clone(&self) -> ScanPolicy
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Default for ScanPolicy
[src]
fn default() -> ScanPolicy
[src]
impl Debug for ScanPolicy
[src]
Auto Trait Implementations
impl Send for ScanPolicy
impl Sync for ScanPolicy
impl Unpin for ScanPolicy
impl UnwindSafe for ScanPolicy
impl RefUnwindSafe for ScanPolicy
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>,