Enum raft4rs::entity::Entry

pub enum Entry {
    Commit {
        pre_term: u64,
        term: u64,
        index: u64,
        commond: Vec<u8>,
    },
    LeaderChange {
        pre_term: u64,
        term: u64,
        index: u64,
        leader: u64,
    },
    MemberChange {
        pre_term: u64,
        term: u64,
        index: u64,
        node_id: u64,
        action: u8,
    },
    Heartbeat {
        term: u64,
        leader: u64,
        committed: u64,
        applied: u64,
    },
    Vote {
        leader: u64,
        term: u64,
        committed: u64,
    },
    ForwardSubmit {
        commond: Vec<u8>,
    },
    ForwardExecute {
        commond: Vec<u8>,
    },
}

Variants

Commit

Fields of Commit

pre_term: u64term: u64index: u64commond: Vec<u8>

LeaderChange

Fields of LeaderChange

pre_term: u64term: u64index: u64leader: u64

MemberChange

Fields of MemberChange

pre_term: u64term: u64index: u64node_id: u64action: u8

Heartbeat

Fields of Heartbeat

term: u64leader: u64committed: u64applied: u64

Vote

Fields of Vote

leader: u64term: u64committed: u64

ForwardSubmit

Fields of ForwardSubmit

commond: Vec<u8>

ForwardExecute

Fields of ForwardExecute

commond: Vec<u8>

Implementations

impl Entry

pub fn info(&self) -> (u64, u64)

pub fn commit_info(&self) -> (u64, u64, u64)

pub async fn decode_stream<'_>(
    stream: &'_ mut TcpStream
) -> RaftResult<(u64, Self)>

Trait Implementations

impl Clone for Entry

fn clone(&self) -> Entry

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Entry

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

Formats the value using the given formatter.

impl Decode for Entry

type Item = Self

fn decode(buf: &[u8]) -> RaftResult<Self::Item>

impl Encode for Entry

fn encode(&self) -> Vec<u8>