Struct ActiveTransaction 

pub struct ActiveTransaction {
    pub id: TxnId,
    pub start_ts: Timestamp,
    pub state: TxnState,
    pub snapshot: Snapshot,
    /* private fields */
}

Active transaction tracking

Fields

id: TxnId

Transaction ID

start_ts: Timestamp

Start timestamp

state: TxnState

State

snapshot: Snapshot

Snapshot for reads

Implementations

impl ActiveTransaction

pub fn new(id: TxnId, active_txns: Vec<TxnId>) -> Self

Create new transaction

pub fn record_read(&mut self, key: &[u8])

Record a read

pub fn record_write(&mut self, key: &[u8])

Record a write

pub fn write_set(&self) -> &[Vec<u8>]

Get write set

pub fn read_set(&self) -> &[Vec<u8>]

Get read set

pub fn commit(&mut self)

Mark as committed

pub fn abort(&mut self)

Mark as aborted

pub fn is_active(&self) -> bool

Check if active

Trait Implementations

impl Debug for ActiveTransaction

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

Formats the value using the given formatter.