Struct FileReplicationLog 

pub struct FileReplicationLog { /* private fields */ }

File-backed append-only replication log for local runtime sync.

Implementations

impl FileReplicationLog

pub fn new( storage_path: impl AsRef<Path>, relative_path: &str, ) -> SyncResult<Self>

Opens a relative append-only log below storage_path.

pub fn file_path(&self) -> &Path

Returns the durable log file path.

pub fn reload(&mut self) -> SyncResult<()>

Re-reads and validates all durable records from disk.

Trait Implementations

impl Clone for FileReplicationLog

fn clone(&self) -> FileReplicationLog

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileReplicationLog

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

Formats the value using the given formatter.

impl Eq for FileReplicationLog

impl PartialEq for FileReplicationLog

fn eq(&self, other: &FileReplicationLog) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl ReplicationLog for FileReplicationLog

fn append(&mut self, record: Vec<u8>) -> SyncResult<usize>

Appends an unsequenced record and returns its one-based log index.

fn append_with_sequence( &mut self, record: Vec<u8>, sequence: u64, ) -> SyncResult<usize>

Idempotently appends record at a source sequence.

fn event_at_sequence(&self, sequence: u64) -> SyncResult<Option<Vec<u8>>>

Returns the payload at a source sequence when sequence lookup is supported.

fn events_since(&self, index: usize) -> SyncResult<Vec<Vec<u8>>>

Returns payloads after the supplied zero-based log offset.

fn last_index(&self) -> usize

Returns the one-based final log index, or zero for an empty log.

fn len(&self) -> usize

Returns the number of records in the log.

fn is_empty(&self) -> bool

Reports whether the log contains no records.

fn create_snapshot(&self) -> SyncResult<ReplicationSnapshot>

Creates a validated portable snapshot when supported.

fn restore_snapshot(&mut self, snapshot: &ReplicationSnapshot) -> SyncResult<()>

Atomically replaces log contents from a validated snapshot when supported.

impl StructuralPartialEq for FileReplicationLog