Struct raft::RaftLog

pub struct RaftLog<T: Storage> {
    pub store: T,
    pub unstable: Unstable,
    pub committed: u64,
    pub applied: u64,
    pub tag: String,
}

Raft log implementation

Fields

store: T

unstable: Unstable

committed: u64

applied: u64

tag: String

Methods

impl<T: Storage> RaftLog<T>

pub fn new(storage: T, tag: String) -> RaftLog<T>

pub fn last_term(&self) -> u64

pub fn get_store(&self) -> &T

pub fn mut_store(&mut self) -> &mut T

pub fn term(&self, idx: u64) -> Result<u64>

pub fn first_index(&self) -> u64

pub fn last_index(&self) -> u64

pub fn find_conflict(&self, ents: &[Entry]) -> u64

pub fn match_term(&self, idx: u64, term: u64) -> bool

pub fn maybe_append(     &mut self,     idx: u64,     term: u64,     committed: u64,     ents: &[Entry] ) -> Option<u64>

pub fn commit_to(&mut self, to_commit: u64)

pub fn applied_to(&mut self, idx: u64)

pub fn get_applied(&self) -> u64

pub fn stable_to(&mut self, idx: u64, term: u64)

pub fn stable_snap_to(&mut self, idx: u64)

pub fn get_unstable(&self) -> &Unstable

pub fn append(&mut self, ents: &[Entry]) -> u64

pub fn unstable_entries(&self) -> Option<&[Entry]>

pub fn entries(&self, idx: u64, max_size: u64) -> Result<Vec<Entry>>

pub fn all_entries(&self) -> Vec<Entry>

pub fn is_up_to_date(&self, last_index: u64, term: u64) -> bool

pub fn next_entries_since(&self, since_idx: u64) -> Option<Vec<Entry>>

pub fn next_entries(&self) -> Option<Vec<Entry>>

pub fn has_next_entries_since(&self, since_idx: u64) -> bool

pub fn has_next_entries(&self) -> bool

pub fn snapshot(&self) -> Result<Snapshot>

pub fn maybe_commit(&mut self, max_index: u64, term: u64) -> bool

pub fn slice(&self, low: u64, high: u64, max_size: u64) -> Result<Vec<Entry>>

pub fn restore(&mut self, snapshot: Snapshot)

Trait Implementations

impl<T: Default + Storage> Default for RaftLog<T>

fn default() -> RaftLog<T>

Returns the "default value" for a type.

impl<T> ToString for RaftLog<T> where     T: Storage,

fn to_string(&self) -> String

Converts the given value to a String.