Struct raft_engine::internals::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.