Struct TxManager 

pub struct TxManager<S: WriteSetApplicator> { /* private fields */ }

Implementations

impl<S: WriteSetApplicator> TxManager<S>

pub fn new(store: S) -> Self

pub fn new_with_counters( store: S, next_tx: TxId, next_lsn: Lsn, committed_watermark: TxId, ) -> Self

pub fn begin(&self) -> TxId

pub fn snapshot(&self) -> SnapshotId

pub fn with_write_set<F, R>(&self, tx: TxId, f: F) -> Result<R>

where F: FnOnce(&mut WriteSet) -> R,

pub fn cloned_write_set(&self, tx: TxId) -> Result<WriteSet>

pub fn commit(&self, tx: TxId) -> Result<()>

pub fn commit_with_lsn(&self, tx: TxId) -> Result<Lsn>

pub fn rollback(&self, tx: TxId) -> Result<()>

pub fn store(&self) -> &S

pub fn new_row_id(&self) -> RowId

pub fn current_lsn(&self) -> Lsn

pub fn allocate_ddl_lsn<F, R>(&self, f: F) -> R

where F: FnOnce(Lsn) -> R,

pub fn with_commit_lock<F, R>(&self, f: F) -> R

where F: FnOnce() -> R,

pub fn current_tx_max(&self) -> TxId

Returns the highest-committed TxId (the statement-scoped max for user-SQL bound checks against TXID columns). Reads committed_watermark under SeqCst.

pub fn peek_next_tx(&self) -> TxId

Returns the next transaction id the allocator will issue (peek, no increment).

pub fn advance_for_sync(&self, table: &str, incoming: TxId) -> Result<()>

Advances the local TxId allocator past an incoming peer TxId seen during sync-apply. The overflow guard fires on u64::MAX before any mutation so the receiver’s counters are unchanged on error.

Trait Implementations

impl<S: WriteSetApplicator> TransactionManager for TxManager<S>

fn begin(&self) -> TxId

fn commit(&self, tx: TxId) -> Result<()>

fn rollback(&self, tx: TxId) -> Result<()>

fn snapshot(&self) -> SnapshotId