Struct ClusterManager 

pub struct ClusterManager { /* private fields */ }

Cluster Manager — coordinates consensus, membership, and partition assignment

Implementations

impl ClusterManager

pub fn new(self_id: u32, partition_count: u32) -> Self

Create a new cluster manager

Arguments

• self_id: This node’s unique ID
• partition_count: Total partitions for the cluster

pub fn registry(&self) -> &Arc<NodeRegistry>

Get the underlying node registry (for partition routing)

pub fn self_id(&self) -> u32

Get this node’s ID

pub fn current_term(&self) -> u64

Get the current term

pub async fn current_role(&self) -> MemberRole

Get this node’s current role

pub async fn leader_id(&self) -> Option<u32>

Get the current leader ID

pub async fn add_member(&self, member: ClusterMember)

Register a new member in the cluster

pub async fn remove_member(&self, node_id: u32) -> Option<ClusterMember>

Remove a member from the cluster

pub fn update_member_heartbeat( &self, node_id: u32, wal_offset: u64, healthy: bool, )

Update a member’s health status and WAL offset

pub fn get_member(&self, node_id: u32) -> Option<ClusterMember>

Get a member by ID

pub fn all_members(&self) -> Vec<ClusterMember>

Get all members

pub fn healthy_members(&self) -> Vec<ClusterMember>

Get healthy members

pub fn member_count(&self) -> usize

Get the number of members

pub async fn handle_vote_request(&self, request: &VoteRequest) -> VoteResponse

Handle a vote request (simplified Raft RequestVote RPC)

Grants vote if:

1. Request term >= our term
2. We haven’t voted for someone else in this term
3. Candidate’s WAL offset >= our knowledge of the log

pub async fn start_election(&self) -> u64

Start an election: increment term and vote for self

Returns the new term. Caller should then send VoteRequests to other nodes.

pub async fn become_leader(&self, term: u64)

Declare self as leader after winning an election

Should only be called after receiving a majority of votes.

pub async fn accept_leader(&self, leader_id: u32, term: u64)

Accept a leader (after receiving an AppendEntries or heartbeat from a valid leader)

pub fn select_leader_candidate(&self) -> Option<u32>

Select the best candidate for leader from healthy members

Deterministic: highest WAL offset wins; on tie, lowest node ID wins.

pub async fn status(&self) -> ClusterStatus

Get full cluster status