Struct raftify::HeedStorage

pub struct HeedStorage(/* private fields */);

Implementations

impl HeedStorage

pub fn create( log_dir_path: PathBuf, config: &Config, logger: Logger ) -> Result<Self>

Trait Implementations

impl Clone for HeedStorage

fn clone(&self) -> HeedStorage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HeedStorage

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

Formats the value using the given formatter.

impl LogStore for HeedStorage

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

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

fn hard_state(&self) -> Result<HardState>

fn set_hard_state(&mut self, hard_state: &HardState) -> Result<()>

fn set_hard_state_commit(&mut self, commit: u64) -> Result<()>

fn conf_state(&self) -> Result<ConfState>

fn set_conf_state(&mut self, conf_state: &ConfState) -> Result<()>

fn snapshot(&self, request_index: u64, to: u64) -> Result<Snapshot>

fn create_snapshot( &mut self, data: Vec<u8>, index: u64, term: u64 ) -> Result<()>

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

fn last_index(&self) -> Result<u64>

fn all_entries(&self) -> Result<Vec<Entry>>

impl Storage for HeedStorage

fn initial_state(&self) -> Result<RaftState>

initial_state is called when Raft is initialized. This interface will return a RaftState which contains HardState and ConfState.

fn entries( &self, low: u64, high: u64, max_size: impl Into<Option<u64>>, ctx: GetEntriesContext ) -> Result<Vec<Entry>>

Returns a slice of log entries in the range [low, high). max_size limits the total size of the log entries returned if not None, however the slice of entries returned will always have length at least 1 if entries are found in the range.

fn term(&self, idx: u64) -> Result<u64>

Returns the term of entry idx, which must be in the range [first_index()-1, last_index()]. The term of the entry before first_index is retained for matching purpose even though the rest of that entry may not be available.

fn first_index(&self) -> Result<u64>

Returns the index of the first log entry that is possible available via entries, which will always equal to truncated index plus 1.

fn last_index(&self) -> Result<u64>

The index of the last entry replicated in the Storage.

fn snapshot(&self, request_index: u64, to: u64) -> Result<Snapshot>

Returns the most recent snapshot.