Struct ClusterCoordinator 

pub struct ClusterCoordinator { /* private fields */ }

Cluster coordinator for managing RAFT nodes

Implementations

impl ClusterCoordinator

pub fn new(config: ClusterConfig) -> Self

Create a new cluster coordinator

pub async fn set_failover_callback<F>(&self, callback: F)

where F: Fn(NodeId) + Send + Sync + 'static,

Set a callback to be invoked when leader failover is triggered

pub async fn add_node(&self, node_id: NodeId, address: SocketAddr) -> Result<()>

Add a node to the cluster

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

Remove a node from the cluster

pub async fn update_node_state( &self, node_id: NodeId, state: NodeState, ) -> Result<()>

Update node state

pub async fn heartbeat(&self, node_id: NodeId) -> Result<()>

Record heartbeat from a node

pub async fn start_health_monitoring(&self)

Start health monitoring background task

pub async fn trigger_failover(&self) -> Result<()>

Manually trigger failover (for testing or manual intervention)

pub async fn should_trigger_reelection(&self) -> bool

Check if automatic re-election should be triggered

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

Get healthy nodes that can participate in election

pub fn cluster_size(&self) -> usize

Get current cluster size

pub fn healthy_nodes(&self) -> usize

Get number of healthy nodes

pub fn has_quorum(&self) -> bool

Check if cluster has quorum

pub async fn get_leader(&self) -> Option<NodeId>

Get current leader

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

Get all node IDs

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

Get node info

pub fn get_cluster_stats(&self) -> ClusterStats

Get cluster statistics

pub async fn shutdown(&self)

Shutdown the coordinator