Enum RaftMessage 

pub enum RaftMessage {
    VoteRequest {
        term: u64,
        candidate_id: String,
        last_log_index: u64,
        last_log_term: u64,
    },
    VoteResponse {
        term: u64,
        vote_granted: bool,
    },
    AppendEntries {
        term: u64,
        _leader_id: String,
        prev_log_index: u64,
        prev_log_term: u64,
        entries: Vec<RaftLogEntry>,
        leader_commit: u64,
    },
    AppendResponse {
        term: u64,
        success: bool,
        match_index: u64,
        conflict_term: Option<u64>,
        conflict_index: Option<u64>,
    },
    InstallSnapshot {
        term: u64,
        _leader_id: String,
        last_included_index: u64,
        last_included_term: u64,
        offset: u64,
        data: Vec<u8>,
        done: bool,
    },
    ClientRequest {
        request_id: String,
        entry: LogEntry,
        response_tx: Sender<Result<(), OxirsError>>,
    },
}

Raft message types

Variants

VoteRequest

Request vote

Fields

term: u64

candidate_id: String

last_log_index: u64

last_log_term: u64

VoteResponse

Vote response

Fields

term: u64

vote_granted: bool

AppendEntries

Append entries (heartbeat/replication)

Fields

term: u64

_leader_id: String

prev_log_index: u64

prev_log_term: u64

entries: Vec<RaftLogEntry>

leader_commit: u64

AppendResponse

Append entries response

Fields

term: u64

success: bool

match_index: u64

conflict_term: Option<u64>

conflict_index: Option<u64>

InstallSnapshot

Install snapshot

Fields

term: u64

_leader_id: String

last_included_index: u64

last_included_term: u64

offset: u64

data: Vec<u8>

done: bool

ClientRequest

Client request

Fields

request_id: String

entry: LogEntry

response_tx: Sender<Result<(), OxirsError>>

Trait Implementations

impl Debug for RaftMessage

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

Formats the value using the given formatter.