Trait scylla::transport::speculative_execution::SpeculativeExecutionPolicy

pub trait SpeculativeExecutionPolicy: Debug + Send + Sync {
    // Required methods
    fn max_retry_count(&self, context: &Context) -> usize;
    fn retry_interval(&self, context: &Context) -> Duration;
}

The policy that decides if the driver will send speculative queries to the next hosts when the current host takes too long to respond.

Required Methods

fn max_retry_count(&self, context: &Context) -> usize

The maximum number of speculative executions that will be triggered for a given request (does not include the initial request)

fn retry_interval(&self, context: &Context) -> Duration

The delay between each speculative execution

Implementors

impl SpeculativeExecutionPolicy for PercentileSpeculativeExecutionPolicy

impl SpeculativeExecutionPolicy for SimpleSpeculativeExecutionPolicy