Struct FilePersistence 

pub struct FilePersistence { /* private fields */ }

File-based persistence with CRC32 integrity checks.

Layout on disk:

• <dir>/raft_state.json — serialised term + voted_for (atomic write via rename)
• <dir>/raft_log.bin — append-only binary log where each record is: [len:4][term:8][index:8][cmd_len:4][cmd:N][crc32:4]

Implementations

impl FilePersistence

pub fn new(dir: &Path, sync_on_write: bool) -> RaftResult<Self>

Create a new file-based persistence rooted at dir.

Creates the directory if it does not exist.

Trait Implementations

impl RaftPersistence for FilePersistence

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