Struct FileLogStore 

pub struct FileLogStore { /* private fields */ }

Implementations

impl FileLogStore

pub fn open( dir: impl Into<PathBuf>, cluster_id: impl Into<String>, epoch: u64, config_id: u64, ) -> Result<Self>

pub fn open_with_configuration( dir: impl Into<PathBuf>, cluster_id: impl Into<String>, epoch: u64, initial_configuration: ConfigurationState, ) -> Result<Self>

pub fn logical_state(&self) -> Result<LogState>

pub fn configuration_state(&self) -> Result<ConfigurationState>

pub fn install_recovery_anchor( &self, verified_anchor: &RecoveryAnchor, expected_recovery_generation: u64, expected_configuration: &ConfigurationState, ) -> Result<()>

pub fn append_batch_buffered(&self, entries: &[LogEntry]) -> Result<()>

Appends validated entries without issuing a data sync.

Call Self::sync before making the appended entries externally durable.

pub fn sync(&self) -> Result<Option<LogIndex>>

Syncs all buffered appends and returns the durable logical tip.

Trait Implementations

impl Debug for FileLogStore

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

Formats the value using the given formatter.

impl LogStore for FileLogStore

fn append(&self, entry: &LogEntry) -> Result<()>

fn append_batch(&self, entries: &[LogEntry]) -> Result<()>

fn read(&self, index: LogIndex) -> Result<Option<LogEntry>>

fn read_range(&self, range: IndexRange) -> Result<Vec<LogEntry>>

fn last_index(&self) -> Result<Option<LogIndex>>

fn truncate_suffix(&self, from: LogIndex) -> Result<()>

fn compact_prefix( &self, verified_snapshot_anchor: &RecoveryAnchor, ) -> Result<()>