Struct FileLogReader 

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

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> RaftLogReader<C> for FileLogReader<C>

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

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

Get a series of log entries from storage.

async fn read_vote(&mut self) -> Result<Option<C::Vote>, Error>

Return the last saved vote by RaftLogStorage::save_vote.

fn leader_bounded_stream<RB>( &mut self, leader: <C as RaftTypeConfig>::LeaderId, range: RB, ) -> impl Future<Output = impl Stream<Item = Result<<C as RaftTypeConfig>::Entry, LeaderBoundedStreamError<C>>> + OptionalSend> + Send

where RB: RangeBounds<u64> + Clone + Debug + OptionalSend,

Read log entries as a stream, conditional on vote state.

fn entries_stream<RB>( &mut self, range: RB, ) -> impl Future<Output = impl Stream<Item = Result<<C as RaftTypeConfig>::Entry, Error>> + OptionalSend> + Send

where RB: RangeBounds<u64> + Clone + Debug + OptionalSend,

Read log entries as a stream without leader validation.

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

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

fn get_key_log_ids( &mut self, range: RangeInclusive<LogId<C>>, ) -> impl Future<Output = Result<Vec<LogId<C>>, Error>> + Send

Retrieves a list of key log ids that mark the beginning of each Leader.