Enum NodeUpdate 

pub enum NodeUpdate {
    Alive {
        node: NodeId,
        addr: SocketAddr,
        incarnation: u64,
    },
    Suspect {
        node: NodeId,
        incarnation: u64,
    },
    Dead {
        node: NodeId,
        incarnation: u64,
    },
    Left {
        node: NodeId,
    },
    SlotsChanged {
        node: NodeId,
        incarnation: u64,
        slots: Vec<SlotRange>,
    },
    RoleChanged {
        node: NodeId,
        incarnation: u64,
        is_primary: bool,
        replicates: Option<NodeId>,
    },
    VoteRequest {
        candidate: NodeId,
        epoch: u64,
        offset: u64,
    },
    VoteGranted {
        from: NodeId,
        candidate: NodeId,
        epoch: u64,
    },
}

A state update about a node, piggybacked on protocol messages.

Variants

Alive

Node is alive with given incarnation number.

Fields

node: NodeId

addr: SocketAddr

incarnation: u64

Suspect

Node is suspected to be failing.

Fields

node: NodeId

incarnation: u64

Dead

Node has been confirmed dead.

Fields

node: NodeId

incarnation: u64

Left

Node left the cluster gracefully.

Fields

node: NodeId

SlotsChanged

Node’s slot ownership changed.

Fields

node: NodeId

incarnation: u64

slots: Vec<SlotRange>

RoleChanged

Node’s role changed (primary ↔ replica).

Fields

node: NodeId

incarnation: u64

is_primary: bool

true if the node is now a primary, false if replica.

replicates: Option<NodeId>

The primary this node replicates from, if it is a replica.

VoteRequest

A replica is requesting votes to take over a failed primary.

Fields

candidate: NodeId

The candidate requesting votes.

epoch: u64

Config epoch this election is contesting.

offset: u64

Candidate’s replication offset; higher value signals the most up-to-date replica.

VoteGranted

A primary is granting its vote to a candidate replica.

Fields

from: NodeId

The primary casting the vote.

candidate: NodeId

The candidate receiving the vote.

epoch: u64

The epoch this vote is for.

Trait Implementations

impl Clone for NodeUpdate

fn clone(&self) -> NodeUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeUpdate

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

Formats the value using the given formatter.

impl PartialEq for NodeUpdate

fn eq(&self, other: &NodeUpdate) -> 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 StructuralPartialEq for NodeUpdate