Struct FilePipeLogBuilder

pub struct FilePipeLogBuilder<F: FileSystem> { /* private fields */ }

DualPipes factory that can also recover other customized memory states.

Implementations

impl<F: FileSystem> DualPipesBuilder<F>

pub fn new( cfg: Config, file_system: Arc<F>, listeners: Vec<Arc<dyn EventListener>>, ) -> Self

Creates a new builder.

pub fn scan(&mut self) -> Result<()>

Scans for all log files under the working directory. The directory will be created if not exists.

pub fn recover<M: ReplayMachine, FA: Factory<M>>( &mut self, machine_factory: &FA, ) -> Result<(M, M)>

Reads through log items in all available log files, and replays them to specific ReplayMachines that can be constructed via machine_factory.

pub fn recover_queue<M: ReplayMachine, FA: Factory<M>>( &mut self, file_system: Arc<F>, recovery_cfg: RecoveryConfig, replay_machine_factory: &FA, ) -> Result<M>

Manually reads through log items in all available log files of the specified [LogQueue], and replays them to specific ReplayMachines that can be constructed via machine_factory.

pub fn finish(self) -> Result<DualPipes<F>>

Builds a DualPipes that contains all available log files.