Struct scylla::transport::execution_profile::ExecutionProfileBuilder

pub struct ExecutionProfileBuilder { /* private fields */ }

ExecutionProfileBuilder is used to create new ExecutionProfiles

Example

let profile: ExecutionProfile = ExecutionProfile::builder()
    .consistency(Consistency::Three) // as this is the number we shall count to
    .retry_policy(Arc::new(FallthroughRetryPolicy::new()))
    .build();

Implementations

impl ExecutionProfileBuilder

pub fn request_timeout(self, timeout: Option<Duration>) -> Self

Changes client-side timeout. The default is 30 seconds.

Example

let profile: ExecutionProfile = ExecutionProfile::builder()
    .request_timeout(Some(Duration::from_secs(5)))
    .build();

pub fn consistency(self, consistency: Consistency) -> Self

Specify a default consistency to be used for queries. It’s possible to override it by explicitly setting a consistency on the chosen query.

pub fn serial_consistency( self, serial_consistency: Option<SerialConsistency>, ) -> Self

Specify a default serial consistency to be used for queries. It’s possible to override it by explicitly setting a serial consistency on the chosen query.

pub fn load_balancing_policy( self, load_balancing_policy: Arc<dyn LoadBalancingPolicy>, ) -> Self

Sets the load balancing policy. The default is DefaultPolicy.

Example

let profile: ExecutionProfile = ExecutionProfile::builder()
    .load_balancing_policy(Arc::new(DefaultPolicy::default()))
    .build();

pub fn retry_policy(self, retry_policy: Arc<dyn RetryPolicy>) -> Self

Sets the RetryPolicy to use by default on queries. The default is DefaultRetryPolicy. It is possible to implement a custom retry policy by implementing the trait RetryPolicy.

Example

use scylla::transport::retry_policy::DefaultRetryPolicy;
let profile: ExecutionProfile = ExecutionProfile::builder()
    .retry_policy(Arc::new(DefaultRetryPolicy::new()))
    .build();

pub fn speculative_execution_policy( self, speculative_execution_policy: Option<Arc<dyn SpeculativeExecutionPolicy>>, ) -> Self

Sets the speculative execution policy. The default is None.

Example

use std::{sync::Arc, time::Duration};
use scylla::{
    transport::ExecutionProfile,
    transport::speculative_execution::SimpleSpeculativeExecutionPolicy,
};

let policy = SimpleSpeculativeExecutionPolicy {
    max_retry_count: 3,
    retry_interval: Duration::from_millis(100),
};

let profile: ExecutionProfile = ExecutionProfile::builder()
    .speculative_execution_policy(Some(Arc::new(policy)))
    .build();

pub fn build(self) -> ExecutionProfile

Builds the ExecutionProfile after setting all the options.

Example

use scylla::transport::retry_policy::DefaultRetryPolicy;
let profile: ExecutionProfile = ExecutionProfile::builder()
    .retry_policy(Arc::new(DefaultRetryPolicy::new()))
    .build();

Trait Implementations

impl Clone for ExecutionProfileBuilder

fn clone(&self) -> ExecutionProfileBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionProfileBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ExecutionProfileBuilder

fn default() -> Self

Returns the “default value” for a type.