Struct TxnIdManager 

pub struct TxnIdManager { /* private fields */ }

Transaction ID manager that hands out IDs and tracks commit status.

Implementations

impl TxnIdManager

pub fn new() -> TxnIdManager

Create a new manager.

pub fn new_with_initial_txn_id(next_txn_id: u64) -> TxnIdManager

Create a new manager with a custom initial transaction ID. Used when loading persisted state from the catalog.

pub fn new_with_initial_state( next_txn_id: u64, last_committed: u64, ) -> TxnIdManager

Create a new manager with custom initial state. Used when loading persisted state from the catalog.

pub fn current_next_txn_id(&self) -> u64

Get the current next_txn_id value (for persistence).

pub fn begin_transaction(&self) -> TransactionSnapshot

Begin a new transaction and return its snapshot.

The snapshot captures both the allocated transaction ID and the latest committed ID at the moment the transaction starts. These two values are required to evaluate row visibility rules.

pub fn next_txn_id(&self) -> u64

Convenience helper that returns only the allocated transaction ID. Prefer TxnIdManager::begin_transaction when a snapshot is required.

pub fn status(&self, txn_id: u64) -> TxnStatus

Return the status for a given transaction ID.

pub fn mark_committed(&self, txn_id: u64)

Mark a transaction as committed and advance the global watermark.

pub fn mark_aborted(&self, txn_id: u64)

Mark a transaction as aborted.

pub fn last_committed(&self) -> u64

Return the latest committed transaction ID (snapshot watermark).

Trait Implementations

impl Clone for TxnIdManager

fn clone(&self) -> TxnIdManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TxnIdManager

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

Formats the value using the given formatter.

impl Default for TxnIdManager

fn default() -> TxnIdManager

Returns the “default value” for a type.