Struct raft::RaftLog
[−]
[src]
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>
[src]
fn new(storage: T, tag: String) -> RaftLog<T>
[src]
fn last_term(&self) -> u64
[src]
fn get_store(&self) -> &T
[src]
fn mut_store(&mut self) -> &mut T
[src]
fn term(&self, idx: u64) -> Result<u64>
[src]
fn first_index(&self) -> u64
[src]
fn last_index(&self) -> u64
[src]
fn find_conflict(&self, ents: &[Entry]) -> u64
[src]
fn match_term(&self, idx: u64, term: u64) -> bool
[src]
fn maybe_append(
&mut self,
idx: u64,
term: u64,
committed: u64,
ents: &[Entry]
) -> Option<u64>
[src]
&mut self,
idx: u64,
term: u64,
committed: u64,
ents: &[Entry]
) -> Option<u64>
fn commit_to(&mut self, to_commit: u64)
[src]
fn applied_to(&mut self, idx: u64)
[src]
fn get_applied(&self) -> u64
[src]
fn stable_to(&mut self, idx: u64, term: u64)
[src]
fn stable_snap_to(&mut self, idx: u64)
[src]
fn get_unstable(&self) -> &Unstable
[src]
fn append(&mut self, ents: &[Entry]) -> u64
[src]
fn unstable_entries(&self) -> Option<&[Entry]>
[src]
fn entries(&self, idx: u64, max_size: u64) -> Result<Vec<Entry>>
[src]
fn all_entries(&self) -> Vec<Entry>
[src]
fn is_up_to_date(&self, last_index: u64, term: u64) -> bool
[src]
fn next_entries_since(&self, since_idx: u64) -> Option<Vec<Entry>>
[src]
fn next_entries(&self) -> Option<Vec<Entry>>
[src]
fn has_next_entries_since(&self, since_idx: u64) -> bool
[src]
fn has_next_entries(&self) -> bool
[src]
fn snapshot(&self) -> Result<Snapshot>
[src]
fn maybe_commit(&mut self, max_index: u64, term: u64) -> bool
[src]
fn slice(&self, low: u64, high: u64, max_size: u64) -> Result<Vec<Entry>>
[src]
fn restore(&mut self, snapshot: Snapshot)
[src]
Trait Implementations
impl<T: Default + Storage> Default for RaftLog<T>
[src]
impl<T> ToString for RaftLog<T> where
T: Storage,
[src]
T: Storage,