Struct BridgeEventDelegate 

pub struct BridgeEventDelegate<I, A, PD, D = VoidDelegate<I, A>>
where
    I: Id + IdCodec + Clone + Ord + Send + Sync + 'static,
    A: CheapClone + Send + Sync + 'static,
    PD: PlumtreeDelegate<I>,
{ /* private fields */ }

Bridge event delegate that implements Memberlist’s EventDelegate.

This is a wrapper around PlumtreeBridge that implements the full EventDelegate trait for integration with Memberlist.

Type Parameters

• I: Node identifier type
• A: Node address type
• PD: Plumtree delegate type
• D: Inner delegate type (for forwarding events)

Implementations

impl<I, A, PD, D> BridgeEventDelegate<I, A, PD, D>

where I: Id + IdCodec + Clone + Ord + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static, PD: PlumtreeDelegate<I>,

pub fn new( bridge: PlumtreeBridge<I, PD>, ) -> BridgeEventDelegate<I, A, PD, VoidDelegate<I, A>>

Create a new bridge event delegate with a void inner delegate.

pub fn with_inner(bridge: PlumtreeBridge<I, PD>, inner: D) -> Self

Create a new bridge event delegate with a custom inner delegate.

pub fn bridge(&self) -> &PlumtreeBridge<I, PD>

Get a reference to the bridge.

pub fn inner(&self) -> &D

Get a reference to the inner delegate.

Trait Implementations

impl<I, A, PD, D> Clone for BridgeEventDelegate<I, A, PD, D>

where I: Id + IdCodec + Clone + Ord + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static, PD: PlumtreeDelegate<I>, D: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I, A, PD, D> EventDelegate for BridgeEventDelegate<I, A, PD, D>

where I: Id + IdCodec + Clone + Ord + Send + Sync + 'static, A: CheapClone + Send + Sync + 'static, PD: PlumtreeDelegate<I>, D: EventDelegate<Id = I, Address = A>,

type Id = I

The id type of the delegate

type Address = A

The address type of the delegate

async fn notify_join(&self, node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have joined the cluster

async fn notify_leave(&self, node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have left the cluster

async fn notify_update(&self, node: Arc<NodeState<Self::Id, Self::Address>>)

Invoked when a node is detected to have updated, usually involving the meta data.