Struct raft_engine::internals::PurgeManager

pub struct PurgeManager<P>where
    P: PipeLog,{ /* private fields */ }

Implementations

impl<P> PurgeManager<P>where P: PipeLog,

pub fn new( cfg: Arc<Config>, memtables: MemTables, pipe_log: Arc<P>, global_stats: Arc<GlobalStats>, listeners: Vec<Arc<dyn EventListener>> ) -> PurgeManager<P>

pub fn purge_expired_files(&self) -> Result<Vec<u64>>

pub fn must_rewrite_append_queue( &self, watermark: Option<FileSeq>, exit_after_step: Option<u64> )

Rewrite append files with seqno no larger than watermark. When it’s None, rewrite the entire queue. Returns the number of purged files.

pub fn must_rewrite_rewrite_queue(&self)

pub fn must_purge_all_stale(&self)