Struct CompositeDelegate

pub struct CompositeDelegate<I, A, M = DefaultMergeDelegate<I, A>, R = NoopReconnectDelegate<I, A>> { /* private fields */ }

CompositeDelegate is a helpful struct to split the Delegate into multiple small delegates, so that users do not need to implement full Delegate when they only want to custom some methods in the Delegate.

Implementations

impl<I, A> CompositeDelegate<I, A>

pub fn new() -> Self

Returns a new CompositeDelegate.

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

where M: MergeDelegate<Id = I, Address = A>,

pub fn with_merge_delegate<NM>( self, merge: NM, ) -> CompositeDelegate<I, A, NM, R>

Set the MergeDelegate for the CompositeDelegate.

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

pub fn with_reconnect_delegate<NR>( self, reconnect: NR, ) -> CompositeDelegate<I, A, M, NR>

Set the ReconnectDelegate for the CompositeDelegate.

Trait Implementations

impl<I, A> Default for CompositeDelegate<I, A>

fn default() -> Self

Returns the “default value” for a type.

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

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

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

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

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

type Error = <M as MergeDelegate>::Error

The error type of the delegate

type Id = <M as MergeDelegate>::Id

The id type of the delegate

type Address = <M as MergeDelegate>::Address

The address type of the delegate

async fn notify_merge( &self, members: Arc<[Member<Self::Id, Self::Address>]>, ) -> Result<(), Self::Error>

Invoked when a merge could take place. Provides a list of the nodes known by the peer. If the return value is Err, the merge is canceled.

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

The id type of the delegate

type Address = <R as ReconnectDelegate>::Address

The address type of the delegate

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

Returns the reconnect timeout for the given member.