Trait ClusterEvents 

pub trait ClusterEvents:
    Send
    + Sync
    + 'static {
    // Required methods
    fn subscribe(
        &self,
        on_event: Box<dyn Fn(ClusterEvent) + Send + Sync>,
    ) -> Result<SubscriptionId, ClusterError>;
    fn unsubscribe(&self, id: SubscriptionId) -> Result<(), ClusterError>;
}

Subscription to cluster membership events.

Required Methods

fn subscribe( &self, on_event: Box<dyn Fn(ClusterEvent) + Send + Sync>, ) -> Result<SubscriptionId, ClusterError>

Subscribe to cluster membership changes. The callback is invoked for each ClusterEvent (NodeJoined, NodeLeft, NodeRejected). Returns a SubscriptionId that can be used to cancel the subscription.

fn unsubscribe(&self, id: SubscriptionId) -> Result<(), ClusterError>

Remove a previously registered subscription. Idempotent.

Implementors