Struct RaftLoop 

pub struct RaftLoop<A: CommitApplier, F: RequestForwarder = NoopForwarder> { /* private fields */ }

Raft event loop coordinator.

Owns the MultiRaft state (behind Arc<Mutex>) and drives it via periodic ticks. Implements RaftRpcHandler so it can be passed directly to NexarTransport::serve for incoming RPC dispatch.

Implementations

impl<A: CommitApplier> RaftLoop<A>

pub fn new( multi_raft: MultiRaft, transport: Arc<NexarTransport>, topology: Arc<RwLock<ClusterTopology>>, applier: A, ) -> Self

impl<A: CommitApplier, F: RequestForwarder> RaftLoop<A, F>

pub fn with_forwarder( multi_raft: MultiRaft, transport: Arc<NexarTransport>, topology: Arc<RwLock<ClusterTopology>>, applier: A, forwarder: Arc<F>, ) -> Self

Create a RaftLoop with a custom request forwarder (for cluster mode).

pub fn with_vshard_handler(self, handler: VShardEnvelopeHandler) -> Self

Set a handler for incoming VShardEnvelope messages.

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

pub async fn run(&self, shutdown: Receiver<bool>)

Run the event loop until shutdown.

This drives Raft elections, heartbeats, and message dispatch. Call NexarTransport::serve separately with Arc<Self> as the handler.

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

Propose a command to the Raft group owning the given vShard.

Returns (group_id, log_index) on success.

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

Snapshot all Raft group states for observability (SHOW RAFT GROUPS).

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

Propose a configuration change to a Raft group.

Returns (group_id, log_index) on success.

Trait Implementations

impl<A: CommitApplier, F: RequestForwarder> RaftRpcHandler for RaftLoop<A, F>

async fn handle_rpc(&self, rpc: RaftRpc) -> Result<RaftRpc>