Struct RaftStorage 

pub struct RaftStorage { /* private fields */ }

Combined log and state machine storage for Raft.

When disk is Some, all mutations are persisted to the raft directory so that state survives restarts. When None, storage is purely in-memory (used when cluster mode is disabled or no data directory is configured).

Implementations

impl Storage

pub fn new() -> (Arc<Self>, Receiver<ClusterStateData>)

Creates a new in-memory storage instance and returns a receiver that fires whenever the Raft state machine commits entries.

pub fn open( raft_dir: PathBuf, ) -> Result<(Arc<Self>, Receiver<ClusterStateData>), RaftDiskError>

Opens persistent storage at raft_dir, recovering any existing state.

On a fresh start the directory is created and empty files are written. On recovery, the vote, log entries, and snapshot are loaded from disk into memory so the Raft node can resume where it left off.

pub fn has_log_entries(&self) -> bool

Returns true if the log has any entries (indicating a prior run).

Used by the bootstrap path to decide whether to call bootstrap_single() (fresh start) or skip it (recovery from persisted state).

pub fn state(&self) -> Arc<RwLock<ClusterStateData>>

Trait Implementations

impl Debug for Storage

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

Formats the value using the given formatter.

impl Default for Storage

fn default() -> Self

Returns the “default value” for a type.