Struct FileLogStore 

pub struct FileLogStore<C: RaftTypeConfig> { /* private fields */ }

File-backed log store with in-memory cache.

Implementations

impl<C> FileLogStore<C>

where C: RaftTypeConfig<Entry = Entry<C>, Vote = Vote<C>>,

pub fn new(data_dir: &Path) -> Result<Self>

Create a new file-backed log store.

Creates the directory structure if it doesn’t exist, then loads existing state from disk.

Trait Implementations

impl<C: Clone + RaftTypeConfig> Clone for FileLogStore<C>

fn clone(&self) -> FileLogStore<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> RaftLogStorage<C> for FileLogStore<C>

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

type LogReader = FileLogReader<C>

Log reader type.

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

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: &C::Vote) -> Result<(), Error>

Save vote to storage.

async fn append<I>( &mut self, entries: I, callback: IOFlushed<C>, ) -> Result<(), Error>

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_after( &mut self, last_log_id: Option<LogId<C>>, ) -> Result<(), Error>

Truncate logs after last_log_id, exclusive

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

Purge logs up to log_id, inclusive

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

Saves the last committed log id to storage.

async fn read_committed(&mut self) -> Result<Option<LogId<C>>, Error>

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