Struct MembershipManager 

pub struct MembershipManager { /* private fields */ }

Cluster membership manager

Implementations

impl MembershipManager

pub fn new(cluster_state: Arc<ClusterState>, config: MembershipConfig) -> Self

Create a new membership manager

pub async fn start(&mut self) -> Result<(), MembershipError>

Start membership management processes

pub async fn add_node( &self, node_id: NodeId, node_info: NodeInfo, ) -> Result<(), MembershipError>

Add a node to the cluster

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

Remove a node from the cluster

pub async fn update_node( &self, node_id: &NodeId, node_info: NodeInfo, ) -> Result<(), MembershipError>

Update node information

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

Record a heartbeat from a node

pub async fn get_cluster_config(&self) -> ClusterConfig

Get current cluster configuration

pub async fn get_active_nodes(&self) -> Vec<NodeId>

Get list of active nodes

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

Check if a node is active

pub async fn get_cluster_stats(&self) -> ClusterStats

Get cluster statistics

pub fn subscribe_events(&self) -> Receiver<MembershipEvent>

Subscribe to membership events

pub fn command_sender(&self) -> Sender<MembershipCommand>

Get command sender for external commands