Struct TxManager 

pub struct TxManager<S: WriteSetApplicator> { /* private fields */ }

Implementations

impl<S: WriteSetApplicator> TxManager<S>

pub fn new(store: S) -> Self

pub fn new_with_counters( store: S, next_tx: TxId, next_lsn: u64, committed_watermark: TxId, ) -> Self

pub fn begin(&self) -> TxId

pub fn snapshot(&self) -> SnapshotId

pub fn with_write_set<F, R>(&self, tx: TxId, f: F) -> Result<R>

where F: FnOnce(&mut WriteSet) -> R,

pub fn cloned_write_set(&self, tx: TxId) -> Result<WriteSet>

pub fn commit(&self, tx: TxId) -> Result<()>

pub fn commit_with_lsn(&self, tx: TxId) -> Result<u64>

pub fn rollback(&self, tx: TxId) -> Result<()>

pub fn store(&self) -> &S

pub fn new_row_id(&self) -> RowId

pub fn current_lsn(&self) -> u64

pub fn allocate_ddl_lsn<F, R>(&self, f: F) -> R

where F: FnOnce(u64) -> R,

pub fn with_commit_lock<F, R>(&self, f: F) -> R

where F: FnOnce() -> R,

Trait Implementations

impl<S: WriteSetApplicator> TransactionManager for TxManager<S>

fn begin(&self) -> TxId

fn commit(&self, tx: TxId) -> Result<()>

fn rollback(&self, tx: TxId) -> Result<()>

fn snapshot(&self) -> SnapshotId