The easiest speculative execution policy available. It starts another
execution of a query after constant delay of retry_interval and does at most
max_retry_count speculative query executions (not counting the first,
non-speculative one).
To use this policy in Session:
use std::{sync::Arc, time::Duration};
use scylla::{
Session,
SessionBuilder,
speculative_execution::SimpleSpeculativeExecutionPolicy
};
let policy = SimpleSpeculativeExecutionPolicy {
max_retry_count: 3,
retry_interval: Duration::from_millis(100),
};
let session: Session = SessionBuilder::new()
.known_node("127.0.0.1:9042")
.speculative_execution(Arc::new(policy))
.build()
.await?;
On this page