Struct RaftConsensus 

pub struct RaftConsensus { /* private fields */ }

Raft consensus implementation

Implementations

impl RaftConsensus

pub fn new() -> Self

Create a new Raft consensus instance

pub async fn start( &mut self, _cluster_state: Arc<ClusterState>, ) -> Result<(), ConsensusError>

Start the consensus algorithm

pub async fn handle_message( &self, message: RaftMessage, cluster_state: &ClusterState, ) -> Result<(), ConsensusError>

Handle incoming Raft messages

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

Get command sender for client requests

pub fn add_node_channel(&mut self, node_id: NodeId, sender: Sender<RaftMessage>)

Add communication channel for a node