Trait ReconnectDelegate

pub trait ReconnectDelegate:
    Send
    + Sync
    + 'static {
    type Id: Id;
    type Address: CheapClone + Send + Sync + 'static;

    // Required method
    fn reconnect_timeout(
        &self,
        member: &Member<Self::Id, Self::Address>,
        timeout: Duration,
    ) -> Duration;
}

Implemented to allow overriding the reconnect timeout for individual members.

Required Associated Types

type Id: Id

The id type of the delegate

type Address: CheapClone + Send + Sync + 'static

The address type of the delegate

Required Methods

fn reconnect_timeout( &self, member: &Member<Self::Id, Self::Address>, timeout: Duration, ) -> Duration

Returns the reconnect timeout for the given member.

Implementations on Foreign Types

impl<T: ReconnectDelegate + ?Sized> ReconnectDelegate for Box<T>

where Box<T>: Send + Sync + 'static,

type Id = <T as ReconnectDelegate>::Id

type Address = <T as ReconnectDelegate>::Address

fn reconnect_timeout( &self, member: &Member<Self::Id, Self::Address>, timeout: Duration, ) -> Duration

impl<T: ReconnectDelegate + ?Sized> ReconnectDelegate for Arc<T>

where Arc<T>: Send + Sync + 'static,

type Id = <T as ReconnectDelegate>::Id

type Address = <T as ReconnectDelegate>::Address

fn reconnect_timeout( &self, member: &Member<Self::Id, Self::Address>, timeout: Duration, ) -> Duration

Implementors

impl<I, A> ReconnectDelegate for NoopReconnectDelegate<I, A>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static,

type Id = I

type Address = A

impl<I, A, M, R> ReconnectDelegate for CompositeDelegate<I, A, M, R>

where I: Id + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static, M: Send + Sync + 'static, R: ReconnectDelegate<Id = I, Address = A>,

type Id = <R as ReconnectDelegate>::Id

type Address = <R as ReconnectDelegate>::Address