Enum RaftMessage 

pub enum RaftMessage<T> {
    RequestVote {
        term: Term,
        candidate_id: NodeId,
        last_log_index: LogIndex,
        last_log_term: Term,
    },
    RequestVoteResponse {
        term: Term,
        vote_granted: bool,
        from_id: NodeId,
    },
    AppendEntries {
        term: Term,
        leader_id: NodeId,
        prev_log_index: LogIndex,
        prev_log_term: Term,
        entries: Vec<LogEntry<T>>,
        leader_commit: LogIndex,
    },
    AppendEntriesResponse {
        term: Term,
        success: bool,
        match_index: LogIndex,
        from_id: NodeId,
    },
    InstallSnapshot {
        term: Term,
        leader_id: NodeId,
        snapshot: Snapshot<T>,
    },
    InstallSnapshotResponse {
        term: Term,
        success: bool,
        from_id: NodeId,
    },
}

Full Raft RPC message types (per Raft paper §5-7)

Variants

RequestVote

Invoked by candidates to gather votes

Fields

term: Term

Candidate’s term

candidate_id: NodeId

Candidate requesting vote

last_log_index: LogIndex

Index of candidate’s last log entry

last_log_term: Term

Term of candidate’s last log entry

RequestVoteResponse

Response to RequestVote RPC

Fields

term: Term

Current term, for candidate to update itself

vote_granted: bool

True means candidate received vote

from_id: NodeId

Responder’s node ID

AppendEntries

Invoked by leader to replicate log entries; also used as heartbeat

Fields

term: Term

Leader’s term

leader_id: NodeId

So follower can redirect clients

prev_log_index: LogIndex

Index of log entry immediately preceding new ones

prev_log_term: Term

Term of prev_log_index entry

entries: Vec<LogEntry<T>>

Log entries to store (empty for heartbeat)

leader_commit: LogIndex

Leader’s commit index

AppendEntriesResponse

Response to AppendEntries RPC

Fields

term: Term

Current term, for leader to update itself

success: bool

True if follower contained entry matching prev_log_index and prev_log_term

match_index: LogIndex

The index of the last entry replicated (for updating match_index)

from_id: NodeId

Responder’s node ID

InstallSnapshot

Invoked by leader to send chunks of a snapshot to a follower

Fields

term: Term

Leader’s term

leader_id: NodeId

So follower can redirect clients

snapshot: Snapshot<T>

Snapshot data

InstallSnapshotResponse

Response to InstallSnapshot RPC

Fields

term: Term

Current term, for leader to update itself

success: bool

True if snapshot was accepted

from_id: NodeId

Responder’s node ID

Trait Implementations

impl<T: Clone> Clone for RaftMessage<T>

fn clone(&self) -> RaftMessage<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for RaftMessage<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for RaftMessage<T>

where T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for RaftMessage<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.