Enum GossipEvent 

pub enum GossipEvent {
    MemberJoined(NodeId, SocketAddr, Vec<SlotRange>),
    MemberSuspected(NodeId),
    MemberFailed(NodeId),
    MemberLeft(NodeId),
    MemberAlive(NodeId),
    SlotsChanged(NodeId, Vec<SlotRange>),
    RoleChanged(NodeId, bool, Option<NodeId>),
    VoteRequested {
        candidate: NodeId,
        epoch: u64,
        offset: u64,
    },
    VoteGranted {
        from: NodeId,
        candidate: NodeId,
        epoch: u64,
    },
}

Events emitted by the gossip engine.

Variants

MemberJoined(NodeId, SocketAddr, Vec<SlotRange>)

A new node joined the cluster.

MemberSuspected(NodeId)

A node is suspected to be failing.

MemberFailed(NodeId)

A node has been confirmed dead.

MemberLeft(NodeId)

A node left gracefully.

MemberAlive(NodeId)

A node that was suspected is now alive.

SlotsChanged(NodeId, Vec<SlotRange>)

A node’s slot ownership changed.

RoleChanged(NodeId, bool, Option<NodeId>)

A node’s role changed. Fields: node ID, is_primary, replicates.

VoteRequested

A replica requested votes for a failover election.

Fields

candidate: NodeId

epoch: u64

offset: u64

Candidate’s replication offset at the time of the request.

VoteGranted

A primary granted its vote to a candidate.

Fields

from: NodeId

candidate: NodeId

epoch: u64

Trait Implementations

impl Clone for GossipEvent

fn clone(&self) -> GossipEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GossipEvent

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

Formats the value using the given formatter.