Enum ClusterEvent 

#[non_exhaustive]
pub enum ClusterEvent {
    NodeJoined(NodeId),
    NodeLeft(NodeId),
    NodeRejected {
        node_id: NodeId,
        reason: NodeRejectionReason,
        detail: String,
    },
}

Events emitted by the cluster membership system.

Subscribe via ClusterEvents::subscribe to react to topology changes such as scaling, failover, or planned maintenance.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

NodeJoined(NodeId)

A new node has joined the cluster and is ready to receive messages.

NodeLeft(NodeId)

A node has left the cluster (gracefully or due to failure).

NodeRejected

A node attempted to join but was rejected during the version handshake.

This event is emitted when a connecting node fails the compatibility check (different wire protocol version or adapter) or when the handshake transport call itself fails. The rejected node does not appear in the cluster’s node list.

Fields

node_id: NodeId

The node that was rejected.

reason: NodeRejectionReason

Why the node was rejected.

detail: String

Human-readable detail message.

Trait Implementations

impl Clone for ClusterEvent

fn clone(&self) -> ClusterEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for ClusterEvent

fn eq(&self, other: &ClusterEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ClusterEvent

impl StructuralPartialEq for ClusterEvent