Struct RaftNode 

pub struct RaftNode { /* private fields */ }

A Raft consensus node

Implementations

impl RaftNode

pub fn new(config: RaftConfig) -> RaftResult<Self>

Create a new Raft node

pub fn node_id(&self) -> NodeId

Get the current node ID

pub fn current_term(&self) -> Term

Get the current term

pub fn state(&self) -> NodeState

Get the current state

pub fn leader_id(&self) -> Option<NodeId>

Get the current leader ID

pub fn is_leader(&self) -> bool

Check if this node is the leader

pub fn commit_index(&self) -> LogIndex

Get the commit index

pub fn last_log_index(&self) -> LogIndex

Get the last log index

pub fn propose(&self, command: Command) -> RaftResult<LogIndex>

Append a command to the log (leader only)

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

Handle a RequestVote RPC

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

Handle an AppendEntries RPC

pub fn start_election(&self) -> Vec<RequestVoteRequest>

Start an election (transition to candidate)

pub fn handle_vote_response( &self, from: NodeId, resp: RequestVoteResponse, ) -> bool

Handle a vote response during election

pub fn create_heartbeats(&self) -> Vec<(NodeId, AppendEntriesRequest)>

Create heartbeat messages for all peers

pub fn create_replication_requests(&self) -> Vec<(NodeId, AppendEntriesRequest)>

Create replication messages for all peers

pub fn handle_replication_response( &self, from: NodeId, resp: AppendEntriesResponse, ) -> RaftResult<()>

Handle a replication response

pub fn election_timeout_elapsed(&self) -> bool

Check if election timeout has elapsed

pub fn reset_election_timer(&self)

Reset election timer