Trait scylla::transport::load_balancing::LoadBalancingPolicy

pub trait LoadBalancingPolicy: Send + Sync {
    fn plan<'a>(
        &self, 
        statement: &Statement<'_>, 
        cluster: &'a ClusterData
    ) -> Plan<'a>;
    fn name(&self) -> String;
}

Policy that decides which nodes to contact for each query

Required Methods

fn plan<'a>(
    &self,
    statement: &Statement<'_>,
    cluster: &'a ClusterData
) -> Plan<'a>

It is used for each query to find which nodes to query first

fn name(&self) -> String

Returns name of load balancing policy

Implementors

impl LoadBalancingPolicy for DcAwareRoundRobinPolicy

impl LoadBalancingPolicy for RoundRobinPolicy

impl LoadBalancingPolicy for TokenAwarePolicy