Struct SubscribleEventDelegate 

pub struct SubscribleEventDelegate<I, A>(/* private fields */);

Used to enable an application to receive events about joins and leaves over a subscriber instead of a direct function call.

Implementations

impl<I, A> SubscribleEventDelegate<I, A>

pub fn unbounded() -> (Self, EventSubscriber<I, A>)

Creates a new EventDelegate and unbounded subscriber.

pub fn bounded(capacity: usize) -> (Self, EventSubscriber<I, A>)

Creates a new EventDelegate and bounded subscriber.

Care must be taken that events are processed in a timely manner from the channel, since this delegate will block until an event can be sent.

Trait Implementations

impl<I, A> EventDelegate for SubscribleEventDelegate<I, A>

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

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.

type Id = I

The id type of the delegate