Struct ClusterMembership 

pub struct ClusterMembership { /* private fields */ }

Implementations

impl ClusterMembership

pub fn new(config: ClusterConfig) -> Self

Create a new cluster membership tracker.

pub fn with_min_peer_interval(self, interval: Duration) -> Self

Set the minimum interval between peer additions (builder style).

pub fn config(&self) -> &ClusterConfig

Get the cluster configuration.

pub fn local_node_id(&self) -> &str

Get this node’s ID.

pub fn add_peer(&self, peer: PeerNode) -> Result<(), ClusterError>

Register a peer node.

Rate-limited to at most one addition per min_peer_add_interval (default 100 ms) to prevent join-flood attacks.

pub fn remove_peer(&self, node_id: &str) -> Result<PeerNode, ClusterError>

Remove a peer node.

pub fn update_state( &self, node_id: &str, new_state: NodeState, ) -> Result<(), ClusterError>

Update a peer’s state.

pub fn heartbeat(&self, node_id: &str) -> Result<(), ClusterError>

Record a heartbeat from a peer.

pub fn get_peer(&self, node_id: &str) -> Option<PeerNode>

Get a snapshot of a peer’s state.

pub fn list_peers(&self) -> Vec<(NodeId, NodeState, NodePlatform)>

List all peers with their states.

pub fn count_by_state(&self, state: &NodeState) -> usize

Count peers by state.

pub fn len(&self) -> usize

Count total peers.

pub fn is_empty(&self) -> bool

Check if cluster has no peers.

pub fn add_peer_with_tree( &self, peer: PeerNode, tree: &Mutex<ResourceTree>, ) -> Result<(), ClusterError>

Add a peer and optionally create a resource tree node.

pub fn active_peers(&self) -> Vec<NodeId>

Get all active peer node IDs.