Enum RaftMessage 

pub enum RaftMessage {
    AppendEntries {
        term: u64,
        leader_id: RaftNodeId,
        prev_log_index: u64,
        prev_log_term: u64,
        entries: Vec<Vec<u8>>,
        leader_commit: u64,
    },
    AppendEntriesResponse {
        term: u64,
        success: bool,
        match_index: Option<u64>,
    },
    RequestVote {
        term: u64,
        candidate_id: RaftNodeId,
        last_log_index: u64,
        last_log_term: u64,
    },
    VoteResponse {
        term: u64,
        vote_granted: bool,
    },
    InstallSnapshot {
        term: u64,
        leader_id: RaftNodeId,
        last_included_index: u64,
        last_included_term: u64,
        data: Vec<u8>,
    },
    SnapshotResponse {
        term: u64,
    },
}

Network message types between Raft nodes

Variants

AppendEntries

Append entries (heartbeat or log replication)

Fields

term: u64

Leader’s term

leader_id: RaftNodeId

Leader’s node ID

prev_log_index: u64

Index of log entry preceding new ones

prev_log_term: u64

Term of prev_log_index entry

entries: Vec<Vec<u8>>

Log entries to replicate

leader_commit: u64

Leader’s commit index

AppendEntriesResponse

Append entries response

Fields

term: u64

Current term for leader to update

success: bool

True if follower contained matching entry

match_index: Option<u64>

Last matched log index

RequestVote

Request vote for leader election

Fields

term: u64

Candidate’s term

candidate_id: RaftNodeId

Candidate requesting vote

last_log_index: u64

Index of candidate’s last log entry

last_log_term: u64

Term of candidate’s last log entry

VoteResponse

Vote response

Fields

term: u64

Current term for candidate to update

vote_granted: bool

True if vote granted

InstallSnapshot

Install snapshot

Fields

term: u64

Leader’s term

leader_id: RaftNodeId

Leader’s node ID

last_included_index: u64

Last log index included in snapshot

last_included_term: u64

Last log term included in snapshot

data: Vec<u8>

Snapshot data

SnapshotResponse

Snapshot response

Fields

term: u64

Current term for leader to update

Trait Implementations

impl Clone for RaftMessage

fn clone(&self) -> RaftMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RaftMessage

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

Formats the value using the given formatter.

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

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RaftMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.