Enum MeshPeerEvent 

#[non_exhaustive]
pub enum MeshPeerEvent {
    Joined {
        node_id: String,
        address: Option<String>,
        platform: Option<String>,
        verified: bool,
    },
    Left {
        node_id: String,
    },
    Alive {
        node_id: String,
    },
    Suspect {
        node_id: String,
    },
    Unreachable {
        node_id: String,
    },
    Recovered {
        node_id: String,
        address: Option<String>,
        verified: bool,
    },
}

Live mesh peer membership / health change (WEFT-120).

Published by the mesh runtime whenever a peer joins, leaves, or transitions health state. Consumers (notably ClusterService / ClusterMembership) apply these atomically so cluster membership mirrors mesh state without a pull-based sync_to_membership loop.

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.

Joined

Peer established a mesh connection (or reconnected after drop).

Fields

node_id: String

Remote node id.

address: Option<String>

Network address if known (seed / discovery map).

platform: Option<String>

Platform label when known.

verified: bool

The peer counts as a cluster member: admission verified node_id for this connection, or admission is not enforce (under the default observe, and under off, every peer counts). False only under enforce for a connection whose id is just a claim (a dialled seed, a legacy leaf); membership then holds it as NodeState::Unverified, not Active. Absent in older events (read as false).

Left

Peer disconnected (graceful leave or connection drop).

Fields

node_id: String

Remote node id.

Alive

Heartbeat / successful probe — peer is alive.

Fields

node_id: String

Remote node id.

Suspect

SWIM / heartbeat marked the peer suspect.

Fields

node_id: String

Remote node id.

Unreachable

Peer confirmed unreachable (partition or dead).

Fields

node_id: String

Remote node id.

Recovered

Peer recovered after Unreachable / Suspect (partition recovery).

Fields

node_id: String

Remote node id.

address: Option<String>

Address if known on recovery path.

verified: bool

As for MeshPeerEvent::Joined::verified.

Implementations

impl MeshPeerEvent

pub fn node_id(&self) -> &str

Node id referenced by this event.

Trait Implementations

impl Clone for MeshPeerEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MeshPeerEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MeshPeerEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for MeshPeerEvent

impl PartialEq for MeshPeerEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for MeshPeerEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MeshPeerEvent