Struct ClusterState 

#[non_exhaustive]
pub struct ClusterState {
    pub local_node: NodeId,
    pub nodes: Vec<NodeId>,
    pub is_leader: bool,
    pub wire_version: WireVersion,
    pub app_version: Option<String>,
    pub peer_versions: HashMap<NodeId, PeerVersionInfo>,
}

Snapshot of the cluster state at a point in time.

Includes topology (which nodes are known), version information for each peer, and the local node’s own version metadata. This is the primary type for operational visibility during rolling upgrades.

Invariants

• nodes includes the local node.
• peer_versions excludes the local node (local version info is in wire_version and app_version).
• Every connected remote node in nodes should have a corresponding entry in peer_versions.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

local_node: NodeId

The local node’s identity.

nodes: Vec<NodeId>

All known nodes in the cluster (including local).

is_leader: bool

Whether this node considers itself the leader (if applicable).

wire_version: WireVersion

This node’s wire protocol version.

app_version: Option<String>

This node’s application version, if configured. Purely informational — does not affect compatibility.

peer_versions: HashMap<NodeId, PeerVersionInfo>

Version metadata for each connected remote peer. Populated from successful handshake responses. Keyed by NodeId; does not include the local node.

Implementations

impl ClusterState

pub fn new(local_node: NodeId, nodes: Vec<NodeId>) -> Self

Create a new ClusterState with the given local node and defaults.

Sets wire_version to DACTOR_WIRE_VERSION, app_version to None, is_leader to false, and empty peer_versions.

pub fn node_count(&self) -> usize

Number of nodes in the cluster.

pub fn contains(&self, node_id: &NodeId) -> bool

Check if a specific node is in the cluster.

pub fn peer_version(&self, node_id: &NodeId) -> Option<&PeerVersionInfo>

Look up version information for a remote peer.

Trait Implementations

impl Clone for ClusterState

fn clone(&self) -> ClusterState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterState

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

Formats the value using the given formatter.