Struct raft::storage::MemStorageCore

pub struct MemStorageCore { /* fields omitted */ }

The Memory Storage Core instance holds the actual state of the storage struct. To access this value, use the rl and wl functions on the main MemStorage implementation.

Implementations

impl MemStorageCore

pub fn set_hardstate(&mut self, hs: HardState)

Saves the current HardState.

pub fn hard_state(&self) -> &HardState

Get the hard state.

pub fn mut_hard_state(&mut self) -> &mut HardState

Get the mut hard state.

pub fn commit_to(&mut self, index: u64) -> Result<()>

Commit to an index.

Panics

Panics if there is no such entry in raft logs.

pub fn set_conf_state(&mut self, cs: ConfState)

Saves the current conf state.

pub fn apply_snapshot(&mut self, snapshot: Snapshot) -> Result<()>

Overwrites the contents of this Storage object with those of the given snapshot.

Panics

Panics if the snapshot index is less than the storage’s first index.

pub fn compact(&mut self, compact_index: u64) -> Result<()>

Discards all log entries prior to compact_index. It is the application’s responsibility to not attempt to compact an index greater than RaftLog.applied.

Panics

Panics if compact_index is higher than Storage::last_index(&self) + 1.

pub fn append(&mut self, ents: &[Entry]) -> Result<()>

Append the new entries to storage.

Panics

Panics if ents contains compacted entries, or there’s a gap between ents and the last received entry in the storage.

pub fn commit_to_and_set_conf_states(
    &mut self,
    idx: u64,
    cs: Option<ConfState>
) -> Result<()>

Commit to idx and set configuration to the given states. Only used for tests.

pub fn trigger_snap_unavailable(&mut self)

Trigger a SnapshotTemporarilyUnavailable error.

Trait Implementations

impl Default for MemStorageCore

fn default() -> MemStorageCore

Returns the “default value” for a type.