Struct Cluster 

pub struct Cluster { /* private fields */ }

A distributed cluster of nodes.

Implementations

impl Cluster

pub fn new(local_node: NodeInfo, config: ClusterConfig) -> Self

Create a new cluster.

pub fn id(&self) -> &str

Get the cluster ID.

pub fn config(&self) -> &ClusterConfig

Get the cluster configuration.

pub fn state(&self) -> ClusterState

Get the current cluster state.

pub fn set_state(&self, state: ClusterState)

Set the cluster state.

pub fn local_node_id(&self) -> &NodeId

Get the local node ID.

pub fn leader_id(&self) -> Option<NodeId>

Get the current leader ID.

pub fn set_leader(&self, leader_id: Option<NodeId>)

Set the leader ID.

pub fn is_leader(&self) -> bool

Check if this node is the leader.

pub fn add_node(&self, node: NodeInfo) -> Result<(), ClusterError>

Add a node to the cluster.

pub fn remove_node(&self, node_id: &NodeId) -> Result<NodeInfo, ClusterError>

Remove a node from the cluster.

pub fn get_node(&self, node_id: &NodeId) -> Option<NodeInfo>

Get a node by ID.

pub fn nodes(&self) -> Vec<NodeInfo>

Get all nodes in the cluster.

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

Get all node IDs.

pub fn node_count(&self) -> usize

Get the number of nodes.

pub fn peers(&self) -> Vec<NodeInfo>

Get peer nodes (excluding local).

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

Get peer IDs.

pub fn update_health(&self, health: NodeHealth)

Update node health.

pub fn get_health(&self, node_id: &NodeId) -> Option<NodeHealth>

Get health for a node.

pub fn heartbeat(&self, node_id: &NodeId)

Process heartbeat from a node.

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

Check for failed nodes based on timeout.

pub fn has_quorum(&self) -> bool

Check if cluster has quorum.

pub fn stats(&self) -> ClusterStats

Get cluster statistics.

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

Get nodes that can vote.

pub fn set_node_role(&self, node_id: &NodeId, role: NodeRole)

Update node role.

pub fn leader(&self) -> Option<NodeInfo>

Get the current leader node.