Struct MultiRaft 

pub struct MultiRaft { /* private fields */ }

Multi-Raft coordinator managing multiple Raft groups on a single node.

This coordinator:

• Manages all Raft groups hosted on this node
• Batches heartbeats across groups sharing the same leader
• Routes incoming RPCs to the correct group
• Collects Ready output from all groups for the caller to execute

Implementations

impl MultiRaft

pub fn new(node_id: u64, routing: RoutingTable, data_dir: PathBuf) -> Self

pub fn with_election_timeout(self, min: Duration, max: Duration) -> Self

Configure election timeout range.

pub fn with_heartbeat_interval(self, interval: Duration) -> Self

Configure heartbeat interval.

pub fn add_group(&mut self, group_id: u64, peers: Vec<u64>) -> Result<()>

Initialize a Raft group on this node.

pub fn tick(&mut self) -> MultiRaftReady

Tick all Raft groups. Returns aggregated ready output.

pub fn propose(&mut self, vshard_id: u16, data: Vec<u8>) -> Result<(u64, u64)>

Propose a command to the Raft group that owns the given vShard.

Returns (group_id, log_index) on success.

pub fn handle_append_entries( &mut self, req: &AppendEntriesRequest, ) -> Result<AppendEntriesResponse>

Route an AppendEntries RPC to the correct group.

pub fn handle_request_vote( &mut self, req: &RequestVoteRequest, ) -> Result<RequestVoteResponse>

Route a RequestVote RPC to the correct group.

pub fn handle_install_snapshot( &mut self, req: &InstallSnapshotRequest, ) -> Result<InstallSnapshotResponse>

Route an InstallSnapshot RPC to the correct group.

pub fn snapshot_metadata(&self, group_id: u64) -> Result<(u64, u64, u64)>

Get the current term and snapshot metadata for a group (for building InstallSnapshot RPCs).

pub fn handle_append_entries_response( &mut self, group_id: u64, peer: u64, resp: &AppendEntriesResponse, ) -> Result<()>

Handle AppendEntries response for a specific group.

pub fn handle_request_vote_response( &mut self, group_id: u64, peer: u64, resp: &RequestVoteResponse, ) -> Result<()>

Handle RequestVote response for a specific group.

pub fn advance_applied(&mut self, group_id: u64, applied_to: u64) -> Result<()>

Advance applied index for a group after processing committed entries.

pub fn routing(&self) -> &RoutingTable

pub fn routing_mut(&mut self) -> &mut RoutingTable

pub fn node_id(&self) -> u64

pub fn group_count(&self) -> usize

pub fn groups_mut(&mut self) -> &mut HashMap<u64, RaftNode<RedbLogStorage>>

Mutable access to the underlying Raft groups (for testing / bootstrap).

pub fn propose_conf_change( &mut self, group_id: u64, change: &ConfChange, ) -> Result<(u64, u64)>

Propose a configuration change to a Raft group.

The change is proposed as a regular Raft log entry with a special prefix. When committed, the state machine applies it via [reconfigure_group].

Returns (group_id, log_index) on success.

pub fn apply_conf_change( &mut self, group_id: u64, change: &ConfChange, ) -> Result<()>

Apply a committed configuration change to a Raft group.

Called by the state machine after a ConfChange entry is committed. Also updates the RoutingTable’s group membership.

pub fn match_index_for(&self, group_id: u64, peer: u64) -> Option<u64>

Query a peer’s match_index from a specific Raft group’s leader state.

pub fn group_statuses(&self) -> Vec<GroupStatus>

Snapshot of all Raft group states for observability.

pub fn leader_for_vshard(&self, vshard_id: u16) -> Result<Option<u64>>

Get the leader for a given vShard (from local group state).