Struct RaftLog

pub struct RaftLog<T: Types> { /* private fields */ }

Implementations

impl<T: Types> RaftLog<T>

pub fn dump_data(&self) -> DumpData<T>

Dump log data

pub fn dump(&self) -> RefDump<'_, T>

pub fn config(&self) -> &Config

pub fn open(config: Arc<Config>) -> Result<Self, Error>

pub fn load_chunk_ids(config: &Config) -> Result<Vec<ChunkId>, Error>

pub fn update_state(&mut self, state: RaftLogState<T>) -> Result<Segment, Error>

pub fn read( &self, from: u64, to: u64, ) -> impl Iterator<Item = Result<(T::LogId, T::LogPayload), Error>> + '_

pub fn log_state(&self) -> &RaftLogState<T>

pub fn access_stat(&self) -> &AccessStat

pub fn on_disk_size(&self) -> u64

Trait Implementations

impl<T: Debug + Types> Debug for RaftLog<T>

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

Formats the value using the given formatter.

impl<T: Types> RaftLogWriter<T> for RaftLog<T>

fn truncate(&mut self, index: u64) -> Result<Segment, Error>

Truncate at index, keep the record before index.

fn save_user_data( &mut self, user_data: Option<T::UserData>, ) -> Result<Segment, Error>

Update the Raft log state.

fn save_vote(&mut self, vote: T::Vote) -> Result<Segment, Error>

Save the vote.

fn append<I>(&mut self, entries: I) -> Result<Segment, Error>

where I: IntoIterator<Item = (T::LogId, T::LogPayload)>,

Append a batch of entries to the log.

fn purge(&mut self, upto: T::LogId) -> Result<Segment, Error>

Purge the log entries before and at the given log id.

fn commit(&mut self, log_id: T::LogId) -> Result<Segment, Error>

Update the committed log id.

fn flush(&mut self, callback: T::Callback) -> Result<(), Error>

Request to flush all written data to persistent storage.