Struct ReplicatedLog 

pub struct ReplicatedLog { /* private fields */ }

Replicated log with bounded capacity

Implementations

impl ReplicatedLog

pub fn new(max_size: usize) -> Self

Create a new log with the given maximum capacity

pub fn append( &mut self, term: u64, command: impl Into<String>, data: Vec<u8>, ) -> u64

Append an entry and return its assigned index.

If the log exceeds max_size, the oldest entry is dropped (compaction).

pub fn last_index(&self) -> u64

Return the index of the last entry (0 if empty).

pub fn last_term(&self) -> u64

Return the term of the last entry (0 if empty).

pub fn commit_up_to(&mut self, index: u64)

Advance the commit index up to index.

pub fn apply_committed(&mut self) -> Vec<LogEntry>

Advance last_applied to match commit_index and return applied entries.

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

Get entry by 1-based index (may not exist after compaction).

pub fn commit_index(&self) -> u64

Return current commit index.

pub fn len(&self) -> usize

Return the number of retained entries.

pub fn is_empty(&self) -> bool

True if no entries have been appended (or all were compacted away).