Struct ClusterNode 

pub struct ClusterNode {
    pub id: NodeId,
    pub addr: SocketAddr,
    pub cluster_bus_addr: SocketAddr,
    pub role: NodeRole,
    pub slots: Vec<SlotRange>,
    pub replicates: Option<NodeId>,
    pub replicas: Vec<NodeId>,
    pub last_seen: Instant,
    pub last_ping_sent: Option<Instant>,
    pub last_pong_received: Option<Instant>,
    pub flags: NodeFlags,
    pub config_epoch: u64,
}

Information about a single node in the cluster.

Fields

id: NodeId

Unique node identifier.

addr: SocketAddr

Address for client connections.

cluster_bus_addr: SocketAddr

Address for cluster bus (gossip) connections. Typically addr.port + 10000.

role: NodeRole

Node’s role in the cluster.

slots: Vec<SlotRange>

Slot ranges assigned to this node (only for primaries).

replicates: Option<NodeId>

If this is a replica, the ID of its primary.

replicas: Vec<NodeId>

IDs of nodes replicating this one (if primary).

last_seen: Instant

Last time we received a message from this node.

last_ping_sent: Option<Instant>

Last time we sent a ping to this node.

last_pong_received: Option<Instant>

Last time we received a pong from this node.

flags: NodeFlags

Status flags.

config_epoch: u64

Configuration epoch (used for conflict resolution).

Implementations

impl ClusterNode

pub fn new_primary(id: NodeId, addr: SocketAddr) -> Self

Creates a new primary node with the default bus port offset (10000).

pub fn new_primary_with_offset( id: NodeId, addr: SocketAddr, bus_port_offset: u16, ) -> Self

Creates a new primary node with a custom bus port offset.

pub fn new_replica(id: NodeId, addr: SocketAddr, primary_id: NodeId) -> Self

Creates a new replica node.

pub fn set_myself(&mut self)

Marks this node as the local node.

pub fn is_healthy(&self) -> bool

Returns true if this node is healthy and can serve requests.

pub fn slot_count(&self) -> u16

Returns the total number of slots owned by this node.

pub fn to_cluster_nodes_line(&self, slot_map: &SlotMap) -> String

Formats the node in CLUSTER NODES output format.

Trait Implementations

impl Clone for ClusterNode

fn clone(&self) -> ClusterNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterNode

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

Formats the value using the given formatter.