Struct ActiveTxRegistry 

pub struct ActiveTxRegistry { /* private fields */ }

Live-transaction table. Cheap to clone (internally Arc-wrapped state); pass clones into worker threads.

Implementations

impl ActiveTxRegistry

pub fn new() -> Self

Creates an empty registry. Equivalent to Default::default().

pub fn register(&self, clock: &MvccClock) -> TxHandle

Registers a new transaction. Allocates a fresh TxId from clock and snapshots the current clock value as the transaction’s begin_ts.

Returns a TxHandle — when the handle drops, the transaction is automatically unregistered. RAII keeps the “did the transaction’s caller forget to clean up?” failure mode out of the cold-path code.

pub fn min_active_begin_ts(&self) -> Option<u64>

Returns the begin-timestamp of the oldest in-flight transaction, or None when nothing is in flight. Phase 11.6 uses this to set the GC watermark — versions whose end timestamp is strictly less than this value can never be seen again and may be reclaimed.

pub fn active_count(&self) -> usize

Number of in-flight transactions. Cheap diagnostic accessor; not load-bearing for correctness.

Trait Implementations

impl Clone for ActiveTxRegistry

fn clone(&self) -> ActiveTxRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActiveTxRegistry

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

Formats the value using the given formatter.

impl Default for ActiveTxRegistry

fn default() -> ActiveTxRegistry

Returns the “default value” for a type.