Struct RaftLog 

pub struct RaftLog { /* private fields */ }

The Raft replicated log

Implementations

impl RaftLog

pub fn new() -> Self

Create a new empty log

pub fn last_index(&self) -> LogIndex

Get the index of the last log entry

pub fn last_term(&self) -> Term

Get the term of the last log entry

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

Get the term at a specific index

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

Get a log entry at a specific index

pub fn entries_from(&self, start_index: LogIndex) -> Vec<LogEntry>

Get entries starting from an index

pub fn append(&mut self, term: Term, command: Vec<u8>) -> LogIndex

Append a new entry to the log

pub fn append_entries(&mut self, entries: Vec<LogEntry>) -> RaftResult<()>

Append multiple entries (for replication)

pub fn truncate_from(&mut self, index: LogIndex) -> RaftResult<()>

Truncate log from a given index (delete entries >= index)

pub fn matches(&self, index: LogIndex, term: Term) -> bool

Check if log contains an entry at index with the given term

pub fn install_snapshot(&mut self, snapshot: Snapshot) -> RaftResult<()>

Install a snapshot and compact the log

pub fn create_snapshot( &mut self, up_to_index: LogIndex, data: Vec<u8>, configuration: Vec<String>, ) -> RaftResult<Snapshot>

Create a snapshot up to the given index

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

Get the current snapshot

pub fn len(&self) -> usize

Get the number of entries in memory

pub fn is_empty(&self) -> bool

Check if the log is empty

pub fn base_index(&self) -> LogIndex

Get the base index from snapshot

pub fn base_term(&self) -> Term

Get the base term from snapshot

Trait Implementations

impl Clone for RaftLog

fn clone(&self) -> RaftLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RaftLog

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

Formats the value using the given formatter.

impl Default for RaftLog

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RaftLog

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RaftLog

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.