Struct raft_consensus::persistent_log::fs::FsLog

pub struct FsLog { /* fields omitted */ }

Stores log on disk as 8 bytes for the version identifier, 8 bytes for current_term, 8 bytes for voted_for, and as much as needed for the log. Each log entry is stored as an 8 byte length specifier which is the total length of the entry in bytes, including the length specifier, followed by 8 bytes specifying the term, plus a variable length entry, which is the serialized command sent to raft by the client.

Methods

impl FsLog

pub fn new(filename: &Path) -> Result<FsLog>

Trait Implementations

impl Debug for FsLog

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Log for FsLog

type Error = Error

fn current_term(&self) -> Result<Term>

Returns the latest known term.

fn set_current_term(&mut self, term: Term) -> Result<()>

Sets the current term to the provided value. The provided term must be greater than the current term. The voted_for value will be reset`.

fn inc_current_term(&mut self) -> Result<Term>

Increment the current term. The voted_for value will be reset.

fn voted_for(&self) -> Result<Option<ServerId>>

Returns the candidate id of the candidate voted for in the current term (or none).

fn set_voted_for(&mut self, address: ServerId) -> Result<()>

Sets the candidate id voted for in the current term.

fn latest_log_index(&self) -> Result<LogIndex>

Returns the index of the latest persisted log entry (0 if the log is empty).

fn latest_log_term(&self) -> Result<Term>

Returns the term of the latest persisted log entry (0 if the log is empty).

fn entry<W: Write>(&self, index: LogIndex, buf: Option<W>) -> Result<Term>

Returns the term for the entry at the provided log index writing entry itself to writer if requested

fn append_entries<R: Read, I: Iterator<Item = (Term, R)>>(
    &mut self,
    from: LogIndex,
    entries: I
) -> Result<(), Self::Error>

Append entries sent from the leader.

impl Clone for FsLog

fn clone(&self) -> FsLog

Returns a copy of the value.

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

Performs copy-assignment from source.