Enum TransactionMultiVersion 

#[repr(u8)]
pub enum TransactionMultiVersion {
    Optimistic(TransactionOptimistic),
    Serializable(TransactionSerializable),
}

Variants

Optimistic(TransactionOptimistic)

Serializable(TransactionSerializable)

Implementations

impl TransactionMultiVersion

pub fn optimistic( store: TransactionStore, single: TransactionSingleVersion, bus: EventBus, ) -> TransactionMultiVersion

pub fn serializable( store: TransactionStore, single: TransactionSingleVersion, bus: EventBus, ) -> TransactionMultiVersion

pub fn try_wait_for_watermark( &self, version: CommitVersion, timeout: Duration, ) -> Result<(), AwaitWatermarkError>

Wait for the watermark to reach the specified version. Returns Ok(()) if the watermark reaches the version within the timeout, or Err(AwaitWatermarkError) if the timeout expires.

pub fn current_version(&self) -> Result<CommitVersion, Error>

Get the current version from the transaction manager

pub fn done_until(&self) -> CommitVersion

Returns the highest version where ALL prior versions have completed. This is useful for CDC polling to know the safe upper bound for fetching CDC events - all events up to this version are guaranteed to be in storage.

pub fn watermarks(&self) -> (CommitVersion, CommitVersion)

Returns (query_done_until, command_done_until) for debugging watermark state.

Trait Implementations

impl Clone for TransactionMultiVersion

fn clone(&self) -> TransactionMultiVersion

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MultiVersionTransaction for TransactionMultiVersion

type Query = StandardQueryTransaction

type Command = StandardCommandTransaction

fn begin_query( &self, ) -> Result<<TransactionMultiVersion as MultiVersionTransaction>::Query, Error>

fn begin_command( &self, ) -> Result<<TransactionMultiVersion as MultiVersionTransaction>::Command, Error>

fn with_query<F, R>(&self, f: F) -> Result<R, Error>

where F: FnOnce(&mut Self::Query) -> Result<R, Error>,

fn with_command<F, R>(&self, f: F) -> Result<R, Error>

where F: FnOnce(&mut Self::Command) -> Result<R, Error>,

impl WithEventBus for TransactionMultiVersion

fn event_bus(&self) -> &EventBus