Enum Message 

pub enum Message {
    RequestVoteCall {
        header: MessageHeader,
        last_position: LogPosition,
    },
    RequestVoteReply {
        header: MessageHeader,
        vote_granted: bool,
    },
    AppendEntriesCall {
        header: MessageHeader,
        commit_index: LogIndex,
        entries: LogEntries,
    },
    AppendEntriesReply {
        header: MessageHeader,
        last_position: LogPosition,
    },
}

Message for RPC.

Note that this enum does not include the InstallSnapshot RPC, as the specifics of snapshot installation depend heavily on each individual application and are not managed by this crate.

Variants

RequestVoteCall

RequestVote RPC call.

Fields

header: MessageHeader

Message header.

last_position: LogPosition

Last log position of the candidate.

RequestVoteReply

RequestVote RPC reply.

Fields

header: MessageHeader

Message header.

vote_granted: bool

Whether the vote is granted or not.

AppendEntriesCall

AppendEntries RPC call.

Fields

header: MessageHeader

Message header.

commit_index: LogIndex

Leader’s commit index.

entries: LogEntries

Entries to append.

Note that if the entries are too large to fit in a single message, it can be shrinked by calling LogEntries::truncate() before sending.

AppendEntriesReply

AppendEntries RPC reply.

Fields

header: MessageHeader

Message header.

last_position: LogPosition

Last log position of the follower.

Instead of replying a boolean success as defined in the Raft paper, this crate replies the last log position of the follower. With this adjustment, the leader can quickly determine the appropriate match index of the follower, even if the follower is significantly behind the leader.

Implementations

impl Message

pub fn from(&self) -> NodeId

Returns the sender node ID of the message.

pub fn term(&self) -> Term

Returns the term of the message.

pub fn seqno(&self) -> MessageSeqNo

Returns the sequence number of the message.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Hash for Message

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Message

fn eq(&self, other: &Message) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Message

impl StructuralPartialEq for Message