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.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

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

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

Implementors

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

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