Struct FailoverPool 

pub struct FailoverPool<F, P>(/* private fields */)
where
    F: ClientFacts,
    P: ClientTransport;

A pool supports failover to multiple address with optional 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.

NOTE: there’s cycle reference inside FailoverPoolInner and it’s ClientPool, don’t clone FailoverPool as it has custom drop. FailoverPool should be put in Arc for usage.

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

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> Drop for FailoverPool<F, P>

where F: ClientFacts, P: ClientTransport,

fn drop(&mut self)

Executes the destructor for this type.