Struct aerospike::policy::ScanPolicy
source · pub struct ScanPolicy {
pub base_policy: BasePolicy,
pub scan_percent: u8,
pub max_concurrent_nodes: usize,
pub record_queue_size: usize,
pub fail_on_cluster_change: bool,
pub socket_timeout: u32,
pub filter_expression: Option<FilterExpression>,
}
Expand description
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. This is deprected and won’t be sent to the server.
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. This is deprected and won’t be sent to the server.
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.
filter_expression: Option<FilterExpression>
Optional Filter Expression
Implementations§
source§impl ScanPolicy
impl ScanPolicy
sourcepub const fn filter_expression(&self) -> &Option<FilterExpression>
pub const fn filter_expression(&self) -> &Option<FilterExpression>
Get the current Filter Expression
Trait Implementations§
source§impl Clone for ScanPolicy
impl Clone for ScanPolicy
source§fn clone(&self) -> ScanPolicy
fn clone(&self) -> ScanPolicy
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for ScanPolicy
impl Debug for ScanPolicy
Auto Trait Implementations§
impl RefUnwindSafe for ScanPolicy
impl Send for ScanPolicy
impl Sync for ScanPolicy
impl Unpin for ScanPolicy
impl UnwindSafe for ScanPolicy
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Policy for Twhere
T: PolicyLike,
impl<T> Policy for Twhere T: PolicyLike,
source§fn consistency_level(&self) -> &ConsistencyLevel
fn consistency_level(&self) -> &ConsistencyLevel
fn deadline(&self) -> Option<Instant>
source§fn timeout(&self) -> Option<Duration>
fn timeout(&self) -> Option<Duration>
source§fn max_retries(&self) -> Option<usize>
fn max_retries(&self) -> Option<usize>
max_retries
is exceeded, the abort will occur even if
the timeout has not yet been exceeded.