Struct MemLogStore 

pub struct MemLogStore<C: RaftTypeConfig<NodeId = NodeId>> { /* private fields */ }

In-memory Raft log store (v2 API).

Implements RaftLogReader and RaftLogStorage.

Implementations

impl<C: RaftTypeConfig<NodeId = NodeId>> MemLogStore<C>

pub fn new() -> Self

Create a new, empty log store.

Trait Implementations

impl<C: RaftTypeConfig<NodeId = NodeId>> Clone for MemLogStore<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: RaftTypeConfig<NodeId = NodeId>> Default for MemLogStore<C>

fn default() -> Self

Returns the “default value” for a type.

impl<C> RaftLogReader<C> for MemLogStore<C>

where C: RaftTypeConfig<NodeId = NodeId>, C::Entry: Clone,

async fn try_get_log_entries<RB: RangeBounds<u64> + Clone + Debug + OptionalSend>( &mut self, range: RB, ) -> Result<Vec<C::Entry>, StorageError<NodeId>>

Get a series of log entries from storage.

fn limited_get_log_entries( &mut self, start: u64, end: u64, ) -> impl Future<Output = Result<Vec<<C as RaftTypeConfig>::Entry>, StorageError<<C as RaftTypeConfig>::NodeId>>> + Send

Returns log entries within range [start, end), end is exclusive, potentially limited by implementation-defined constraints.

impl<C> RaftLogStorage<C> for MemLogStore<C>

where C: RaftTypeConfig<NodeId = NodeId>, C::Entry: Clone,

type LogReader = MemLogReader<C>

Log reader type.

async fn get_log_state(&mut self) -> Result<LogState<C>, StorageError<NodeId>>

Returns the last deleted log id and the last log id.

async fn get_log_reader(&mut self) -> Self::LogReader

Get the log reader.

async fn save_vote( &mut self, vote: &Vote<NodeId>, ) -> Result<(), StorageError<NodeId>>

Save vote to storage.

async fn read_vote( &mut self, ) -> Result<Option<Vote<NodeId>>, StorageError<NodeId>>

Return the last saved vote by Self::save_vote.

async fn save_committed( &mut self, committed: Option<LogId<NodeId>>, ) -> Result<(), StorageError<NodeId>>

Saves the last committed log id to storage.

async fn read_committed( &mut self, ) -> Result<Option<LogId<NodeId>>, StorageError<NodeId>>

Return the last saved committed log id by Self::save_committed.

async fn append<I>( &mut self, entries: I, callback: LogFlushed<C>, ) -> Result<(), StorageError<NodeId>>

where I: IntoIterator<Item = C::Entry> + OptionalSend, I::IntoIter: OptionalSend,

Append log entries and call the callback once logs are persisted on disk.

async fn truncate( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Truncate logs since log_id, inclusive

async fn purge( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Purge logs upto log_id, inclusive