Struct FailoverPool 

pub struct FailoverPool<F, P>
where
    F: ClientFacts,
    P: ClientTransport,
{ /* private fields */ }

A pool supports failover to multiple address with bias or round_robin strategy

Supports async and blocking context.

Only retry RpcIntErr that less than RpcIntErr::Method, currently ignore custom error due to complexity of generic. (If you need to custom failover logic, copy the code and impl your own pool.)

Implementations

impl<F, P> FailoverPool<F, P>

where F: ClientFacts, P: ClientTransport,

pub fn new( facts: Arc<F>, addrs: Vec<String>, round_robin: bool, retry_limit: usize, pool_channel_size: usize, ) -> Self

Initate the pool with multiple address. When round_robin == true, all address in the pool will be select with equal chanced; When round_robin == false, the first address will always be pick unless error happens.

pub fn update_addrs(&self, addrs: Vec<String>)

Trait Implementations

impl<F, P> ClientCaller for FailoverPool<F, P>

where F: ClientFacts, P: ClientTransport,

type Facts = F

async fn send_req(&self, task: F::Task)

impl<F, P> ClientCallerBlocking for FailoverPool<F, P>

where F: ClientFacts, P: ClientTransport,

type Facts = F

fn send_req_blocking(&self, task: F::Task)

impl<F, P> Clone for FailoverPool<F, P>

where F: ClientFacts, P: ClientTransport,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.