Struct NativeVersionedLog 

pub struct NativeVersionedLog<S: ?Sized> { /* private fields */ }

Versioned transaction log backed by a native key/value-style store.

Implementations

impl<S: NativeLogStorage + ?Sized + 'static> NativeVersionedLog<S>

pub fn open( storage: Arc<S>, name: &str, write_version: u64, ) -> Result<Self, LogError>

Opens the log for writing under write_version.

Errors

Returns an error when stored records cannot be read or decoded.

Trait Implementations

impl<S: NativeLogStorage + ?Sized + 'static> TransactionLog for NativeVersionedLog<S>

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 replay(&self) -> Result<Vec<TxRecord>, LogError>

Replays every committed record.