Struct SqliteReplicationLog 

pub struct SqliteReplicationLog { /* private fields */ }

SQLite-backed implementation of the AppCore replication-log contract.

Implementations

impl SqliteReplicationLog

pub fn events_page( &self, index: usize, max_records: usize, ) -> SyncResult<Vec<Vec<u8>>>

Reads one bounded page after the supplied zero-based log offset.

Trait Implementations

impl Clone for SqliteReplicationLog

fn clone(&self) -> SqliteReplicationLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteReplicationLog

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

Formats the value using the given formatter.

impl ReplicationLog for SqliteReplicationLog

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) -> SyncResult<usize>

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

fn len(&self) -> SyncResult<usize>

Returns the number of records in the log.

fn is_empty(&self) -> SyncResult<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.