Struct ClusterCoordinator 

pub struct ClusterCoordinator { /* private fields */ }

Cluster coordinator managing membership and health

Implementations

impl ClusterCoordinator

pub fn new(config: ClusterConfig, local_node_id: String) -> Self

Create a new cluster coordinator

pub fn with_gossip( config: ClusterConfig, local_node_id: String, local_address: SocketAddr, api_address: String, role: NodeRole, gossip_config: GossipConfig, ) -> Self

Create a cluster coordinator with gossip protocol enabled

Arguments

• config - Cluster configuration
• local_node_id - Unique identifier for this node
• local_address - Socket address for gossip communication (e.g., “0.0.0.0:7946”)
• api_address - API address for client communication (e.g., “http://localhost:8080”)
• role - Role of this node in the cluster
• gossip_config - Gossip protocol configuration

pub async fn start_gossip(&self) -> Result<(), String>

Start the gossip protocol

pub fn stop_gossip(&self)

Stop the gossip protocol

pub async fn leave_cluster(&self) -> Result<(), String>

Leave the cluster gracefully

pub async fn process_gossip_events(&mut self) -> Result<usize, String>

Process pending gossip events and update cluster state

pub fn gossip(&self) -> Option<&Arc<GossipProtocol>>

Get the gossip protocol instance

pub async fn get_gossip_members(&self) -> Vec<GossipMember>

Get all members from the gossip protocol

pub async fn broadcast_metadata( &self, key: String, value: String, ) -> Result<(), String>

Broadcast metadata update via gossip

pub fn register_node(&self, node: NodeInfo) -> Result<(), String>

Register a node with the cluster

pub fn deregister_node(&self, node_id: &str) -> Result<Option<NodeInfo>, String>

Deregister a node from the cluster

pub fn update_node_health( &self, node_id: &str, health: NodeHealth, ) -> Result<(), String>

Update node health status

pub fn record_health_success(&self, node_id: &str) -> Result<(), String>

Record a successful health check

pub fn record_health_failure(&self, node_id: &str) -> Result<(), String>

Record a failed health check

pub fn get_state(&self) -> ClusterState

Get current cluster state

pub fn get_healthy_nodes_for_shard(&self, shard_id: u32) -> Vec<NodeInfo>

Get healthy nodes for a shard

pub fn get_primary_for_shard(&self, shard_id: u32) -> Option<NodeInfo>

Get primary node for a shard

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

Get all healthy nodes

pub fn has_quorum(&self) -> bool

Check if cluster has quorum

pub fn uptime_secs(&self) -> u64

Get cluster uptime in seconds