Struct MemVersionedLog 

pub struct MemVersionedLog { /* private fields */ }

An in-memory transaction log with the same per-lease-version merge semantics as VersionedLog, obtained from a MemLogRegistry. Used by the mem-backed transactor: fully ephemeral, confined to one process.

Trait Implementations

impl TransactionLog for MemVersionedLog

fn append(&self, record: &TxRecord) -> Result<(), LogError>

Durably appends exactly the next transaction.

fn tx_range( &self, start: u64, end: Option<u64>, ) -> Result<Vec<TxRecord>, LogError>

Returns records in the half-open transaction range [start, end).

fn append_async<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 TxRecord, ) -> Pin<Box<dyn Future<Output = Result<(), LogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Durably appends exactly the next transaction without blocking an async runtime worker. Synchronous logs use Self::append by default; storage-backed logs override this method and await their backend.

fn tx_range_async<'life0, 'async_trait>( &'life0 self, start: u64, end: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<TxRecord>, LogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronous form of Self::tx_range.

fn replay(&self) -> Result<Vec<TxRecord>, LogError>

Replays every committed record.

fn replay_async<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<TxRecord>, LogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously replays every committed record.