Struct SsiTransaction 

pub struct SsiTransaction {
    pub txn_id: TxnId,
    pub start_ts: Timestamp,
    pub status: SsiTxnStatus,
    pub commit_ts: Option<Timestamp>,
    pub read_set: HashSet<InlineKey>,
    pub write_set: HashSet<InlineKey>,
    pub in_rw_deps: HashSet<TxnId>,
    pub out_rw_deps: HashSet<TxnId>,
    pub has_committed_in_rw: bool,
    pub has_committed_out_rw: bool,
    /* private fields */
}

Transaction entry for SSI tracking

Fields

txn_id: TxnId

Transaction ID

start_ts: Timestamp

Start timestamp (snapshot time)

status: SsiTxnStatus

Status

commit_ts: Option<Timestamp>

Commit timestamp (if committed)

read_set: HashSet<InlineKey>

Read set (keys this transaction has read) — uses InlineKey (SmallVec<[u8; 32]>) to avoid heap allocation for keys ≤ 32 bytes

write_set: HashSet<InlineKey>

Write set (keys this transaction has written) — uses InlineKey for inline storage

in_rw_deps: HashSet<TxnId>

Incoming rw-antidependencies (transactions that read before this wrote)

out_rw_deps: HashSet<TxnId>

Outgoing rw-antidependencies (transactions that wrote after this read)

has_committed_in_rw: bool

Flag: has incoming from committed transaction

has_committed_out_rw: bool

Flag: has outgoing to committed transaction

Implementations

impl SsiTransaction

pub fn new(txn_id: TxnId, start_ts: Timestamp) -> Self

Create a new SSI transaction

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

Record a read operation (stack-allocated for keys ≤ 32 bytes)

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

Record a write operation (stack-allocated for keys ≤ 32 bytes)

pub fn maybe_read(&self, key: &[u8]) -> bool

Fast Bloom pre-check: might this transaction have read key? False positives possible, false negatives are not.

pub fn is_dangerous(&self) -> bool

Check for dangerous structure (two-in-two-out)

A transaction is part of a dangerous structure if it has:

• At least one incoming rw-antidep from a committed txn, AND
• At least one outgoing rw-antidep to a committed txn

Trait Implementations

impl Debug for SsiTransaction

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

Formats the value using the given formatter.