Struct SsiManager 

pub struct SsiManager { /* private fields */ }

Serializable Snapshot Isolation Manager

Provides serializable isolation level using SSI technique.

Usage

let ssi = SsiManager::new();

// Begin transaction
let (txn_id, snapshot_ts) = ssi.begin()?;

// Read (records rw-dependency)
let value = ssi.read(txn_id, key)?;

// Write (checks write-write conflicts)
ssi.write(txn_id, key, value)?;

// Commit (checks for dangerous structures)
ssi.commit(txn_id)?;

Implementations

impl SsiManager

pub fn new() -> Self

Create a new SSI manager

pub fn begin(&self) -> Result<(TxnId, Timestamp), SsiConflictError>

Begin a new transaction

pub fn record_read( &self, txn_id: TxnId, key: &[u8], ) -> Result<(), SsiConflictError>

Record a read and check for rw-antidependencies

If another concurrent transaction wrote to this key after our snapshot, we have an rw-antidependency (T_reader →ʳʷ T_writer).

pub fn record_write( &self, txn_id: TxnId, key: &[u8], ) -> Result<(), SsiConflictError>

Record a write and check for write-write conflicts

Uses first-updater-wins: if another transaction already wrote to this key after our snapshot, we must abort.

pub fn commit(&self, txn_id: TxnId) -> Result<Timestamp, SsiConflictError>

Commit a transaction

Checks for dangerous structures before allowing commit.

pub fn abort(&self, txn_id: TxnId)

Abort a transaction

pub fn get_status(&self, txn_id: TxnId) -> Option<SsiTxnStatus>

Get transaction status

pub fn get_snapshot_ts(&self, txn_id: TxnId) -> Option<Timestamp>

Get snapshot timestamp for a transaction

pub fn is_visible(&self, txn_id: TxnId, version: &SsiVersionInfo) -> bool

Check if a version is visible to a transaction

pub fn gc(&self, watermark: Timestamp) -> usize

Garbage collection: remove old completed transactions

Trait Implementations

impl Default for SsiManager

fn default() -> Self

Returns the “default value” for a type.