Struct Node 

pub struct Node {
    pub info: NodeInfo,
    pub state: NodeState,
    pub incarnation: u64,
    pub last_seen: Instant,
    pub partition_leader_count: u32,
    pub partition_replica_count: u32,
    pub is_raft_leader: bool,
}

Full node state including runtime information

Fields

info: NodeInfo

Static node information

state: NodeState

Current node state

incarnation: u64

Incarnation number (for SWIM protocol)

last_seen: Instant

Last time we heard from this node

partition_leader_count: u32

Number of partitions led by this node

partition_replica_count: u32

Number of partition replicas on this node

is_raft_leader: bool

Whether this node is the Raft leader

Implementations

impl Node

pub fn new(info: NodeInfo) -> Self

Create a new node from info

pub fn touch(&mut self)

Update last seen time

pub fn mark_alive(&mut self, incarnation: u64) -> bool

Mark as alive with incarnation-based CAS.

Returns true if the transition was accepted.

Enforces state machine rules:

• Unknown/Suspect → Alive: always valid with >= incarnation
• Dead → Alive: only valid with strictly higher incarnation (rejoin)
• Alive → Alive: valid with higher incarnation (state refresh)

pub fn mark_suspect(&mut self) -> bool

Mark as suspect with state machine guard.

Returns true if the transition was accepted.

Only Alive|Unknown → Suspect is valid. Dead → Suspect is explicitly rejected to prevent the Suspect→Dead→Suspect race condition.

pub fn mark_dead(&mut self) -> bool

Mark as dead with state machine guard.

Returns true if the transition was accepted.

Only Suspect → Dead is valid in SWIM. Direct Alive → Dead is rejected (must go through Suspect first). Already Dead is a no-op (idempotent).

pub fn mark_leaving(&mut self) -> bool

Mark as leaving.

Returns true if the transition was accepted. Valid from any non-Dead state (graceful shutdown).

pub fn is_healthy(&self) -> bool

Check if node is healthy

pub fn id(&self) -> &str

Get node ID

pub fn cluster_addr(&self) -> SocketAddr

Get cluster address

pub fn client_addr(&self) -> SocketAddr

Get client address

pub fn load_score(&self) -> u32

Calculate load score (lower is better for placement)

Trait Implementations

impl Clone for Node

fn clone(&self) -> Node

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Node

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

Formats the value using the given formatter.

impl From<&Node> for NodeGossipState

fn from(node: &Node) -> Self

Converts to this type from the input type.