Struct ReplicatedLog 

pub struct ReplicatedLog { /* private fields */ }

The replicated log for Raft consensus.

Implementations

impl ReplicatedLog

pub fn new() -> Self

Create a new replicated log.

pub fn append(&self, entry: LogEntry) -> LogIndex

Append an entry to the log.

pub fn append_entries(&self, new_entries: Vec<LogEntry>) -> LogIndex

Append multiple entries.

pub fn get(&self, index: LogIndex) -> Option<LogEntry>

Get an entry by index.

pub fn get_range(&self, start: LogIndex, end: LogIndex) -> Vec<LogEntry>

Get entries in a range.

pub fn last_index(&self) -> LogIndex

Get the last log index.

pub fn last_term(&self) -> Term

Get the term of the last entry.

pub fn term_at(&self, index: LogIndex) -> Option<Term>

Get the term of an entry at a specific index.

pub fn commit_index(&self) -> LogIndex

Get the commit index.

pub fn set_commit_index(&self, index: LogIndex)

Set the commit index.

pub fn last_applied(&self) -> LogIndex

Get the last applied index.

pub fn set_last_applied(&self, index: LogIndex)

Set the last applied index.

pub fn has_entries_to_apply(&self) -> bool

Check if there are entries to apply.

pub fn next_to_apply(&self) -> Option<LogEntry>

Get the next entry to apply.

pub fn truncate_from(&self, index: LogIndex)

Truncate the log from a given index (inclusive).

pub fn compact(&self, up_to: LogIndex, term: Term)

Compact the log up to a given index.

pub fn len(&self) -> usize

Get the length of the log.

pub fn is_empty(&self) -> bool

Check if the log is empty.

pub fn is_up_to_date( &self, last_log_index: LogIndex, last_log_term: Term, ) -> bool

Check if a log is up-to-date compared to this log.

pub fn find_conflict(&self, entries: &[LogEntry]) -> Option<LogIndex>

Find the conflict point when appending entries.

Trait Implementations

impl Default for ReplicatedLog

fn default() -> Self

Returns the “default value” for a type.