Struct InMemoryReplicationLog 

pub struct InMemoryReplicationLog { /* private fields */ }

In-memory replication log for local sync scenarios.

Implementations

impl InMemoryReplicationLog

pub fn new() -> Self

Creates an empty process-local replication log.

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

Idempotently appends a record at a source sequence.

pub fn last_index(&self) -> usize

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

pub fn contains_sequence(&self, sequence: u64) -> bool

Reports whether a source sequence is present.

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

Restores a snapshot by moving its payload allocations into the log.

This consuming variant avoids retaining the source snapshot and the destination record payloads at the same time. Use the trait method ReplicationLog::restore_snapshot when the caller must keep a borrowed snapshot for compatibility.

Trait Implementations

impl Clone for InMemoryReplicationLog

fn clone(&self) -> InMemoryReplicationLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryReplicationLog

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

Formats the value using the given formatter.

impl Default for InMemoryReplicationLog

fn default() -> InMemoryReplicationLog

Returns the “default value” for a type.

impl Eq for InMemoryReplicationLog

impl PartialEq for InMemoryReplicationLog

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

Equality operator ==.

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

Inequality operator !=.

impl ReplicationLog for InMemoryReplicationLog

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 events_page( &self, index: usize, max_records: usize, max_bytes: usize, ) -> SyncResult<Vec<Vec<u8>>>

Returns one payload page with bounded record count and payload bytes.

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

Returns the number of records in the log.

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

Returns the one-based final log index, or zero for an empty 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.

impl StructuralPartialEq for InMemoryReplicationLog