Struct RaftIndexNode 

pub struct RaftIndexNode { /* private fields */ }

Raft node implementation for distributed vector index

This implements the core Raft protocol. In a production deployment, RPCs would be sent over the network (e.g., gRPC or HTTP/2). Here we provide the state machine logic and expose methods for injecting simulated or actual network messages.

Implementations

impl RaftIndexNode

pub fn new(config: RaftConfig) -> Self

Create a new Raft index node

pub fn start_election(&self) -> RequestVoteRequest

Start an election (become candidate)

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

Handle a RequestVote RPC from a candidate

pub fn process_vote_response(&self, response: RequestVoteResponse) -> bool

Process a vote response from a peer

Returns true if this node just won the election.

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

Handle AppendEntries RPC (from leader)

pub fn process_append_entries_response( &self, peer_id: NodeId, response: AppendEntriesResponse, entries_sent_count: usize, )

Process AppendEntries response from a follower (leader only)

pub fn propose( &self, command: IndexCommand, client_id: Option<String>, ) -> Result<LogIndex>

Propose a new command (leader only)

Returns the log index of the proposed entry, or an error if not leader.

pub fn create_append_entries_request( &self, peer_id: NodeId, ) -> Result<AppendEntriesRequest>

Create an AppendEntries request for a specific follower

pub fn force_commit_single_node(&self)

Force commit a single-node cluster (for testing)

In a single-node cluster, entries are immediately committed.

pub fn role(&self) -> NodeRole

Get the current role

pub fn current_term(&self) -> Term

Get the current term

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

Get the current leader ID (if known)

pub fn is_leader(&self) -> bool

Check if this node is the leader

pub fn log_length(&self) -> usize

Get the number of entries in the log

pub fn commit_index(&self) -> LogIndex

Get the commit index

pub fn last_applied(&self) -> LogIndex

Get the last applied index

pub fn vector_count(&self) -> usize

Get the number of vectors in the state machine

pub fn get_vector(&self, vector_id: &str) -> Option<VectorEntry>

Get a vector from the state machine (read only)

pub fn search_similar(&self, query: &[f32], k: usize) -> Vec<(String, f32)>

Search for similar vectors in the state machine

pub fn get_stats(&self) -> RaftStats

Get current statistics

pub fn election_timeout_elapsed(&self) -> bool

Check if election timeout has elapsed

pub fn reset_heartbeat(&self)

Reset the heartbeat timer (call when receiving valid messages from leader)

Trait Implementations

impl Debug for RaftIndexNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.