Struct Transaction 

pub struct Transaction {
    pub id: TxnId,
    pub state: TxnState,
    pub start_ts: u64,
    pub commit_ts: Option<u64>,
    pub writes: Vec<TxnWrite>,
    pub read_set: HashSet<TxnRead>,
    pub isolation: IsolationLevel,
}

Transaction handle for the user

Fields

id: TxnId

Unique transaction ID

state: TxnState

Transaction state

start_ts: u64

Start timestamp for MVCC

commit_ts: Option<u64>

Commit timestamp (set on commit)

writes: Vec<TxnWrite>

Buffered writes

read_set: HashSet<TxnRead>

Read set for conflict detection

isolation: IsolationLevel

Isolation level

Implementations

impl Transaction

pub fn new(id: TxnId, start_ts: u64, isolation: IsolationLevel) -> Self

Create a new transaction

pub fn put(&mut self, table: &str, key: Vec<u8>, value: Vec<u8>)

Buffer a write operation

pub fn delete(&mut self, table: &str, key: Vec<u8>)

Buffer a delete operation

pub fn record_read(&mut self, table: &str, key: Vec<u8>)

Record a read for conflict detection

pub fn get_local(&self, table: &str, key: &[u8]) -> Option<&TxnWrite>

Check for read-your-writes

pub fn is_read_only(&self) -> bool

Check if transaction has any writes

Trait Implementations

impl Debug for Transaction

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

Formats the value using the given formatter.