Struct MemoryPersistence 

pub struct MemoryPersistence { /* private fields */ }

In-memory persistence backend, useful for tests.

Implementations

impl MemoryPersistence

pub fn new() -> Self

Create a new empty in-memory persistence backend.

Trait Implementations

impl Default for MemoryPersistence

fn default() -> Self

Returns the “default value” for a type.

impl RaftPersistence for MemoryPersistence

fn save_state(&self, term: Term, voted_for: Option<NodeId>) -> RaftResult<()>

Save persistent state (current_term, voted_for)

fn load_state(&self) -> RaftResult<(Term, Option<NodeId>)>

Load persistent state; returns (term, voted_for)

fn append_entries(&self, entries: &[LogEntry]) -> RaftResult<()>

Append log entries to persistent storage

fn load_log(&self) -> RaftResult<Vec<LogEntry>>

Load all log entries from persistent storage

fn truncate_log_from(&self, index: LogIndex) -> RaftResult<()>

Truncate log from index (inclusive) onward

fn last_log_index(&self) -> RaftResult<LogIndex>

Get the last persisted log index (0 if empty)

fn save_applied_index(&self, index: LogIndex) -> RaftResult<()>

Save the applied index to durable storage.

fn load_applied_index(&self) -> RaftResult<LogIndex>

Load the previously persisted applied index (0 if not set).

fn sync(&self) -> RaftResult<()>

Sync all data to durable storage