Struct OwnedTransactionSession 

pub struct OwnedTransactionSession { /* private fields */ }

A transaction session that serializes stream leases and owns exactly one terminal action.

Implementations

impl OwnedTransactionSession

pub fn new(transaction: Box<dyn OwnedKVTransaction>) -> OwnedTransactionSession

Wrap one backend-owned transaction.

pub fn status(&self) -> OwnedTransactionSessionStatus

Return the current transaction/lease lifecycle state.

pub fn acquire_lease(&self) -> Result<OwnedTransactionLease, Error>

Acquire a single active lease. A later lease may start only after normal exhaustion.

pub fn with_transaction<T>( &self, operation: impl FnOnce(&mut dyn OwnedKVTransaction) -> Result<T, Error>, ) -> Result<T, Error>

Run one finite compatibility operation without exposing the active lease.

This is intentionally distinct from a stream lease: the operation cannot retain a cursor, and a successful or classified operation error releases the transaction as committable. A panic or an abandoned lease remains conservative and marks the session MustAbort through OwnedTransactionLease::drop.

pub fn commit(&self) -> Result<OwnedTransactionSessionStatus, Error>

Commit this owned transaction once.

pub fn rollback(&self) -> Result<OwnedTransactionSessionStatus, Error>

Roll back this owned transaction once.

Trait Implementations

impl Clone for OwnedTransactionSession

fn clone(&self) -> OwnedTransactionSession

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OwnedTransactionSession

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

Formats the value using the given formatter.

impl OwnedTransactionSessionApi for OwnedTransactionSession

fn status(&self) -> OwnedTransactionSessionStatus

Return the current one-way lifecycle state.

fn acquire_lease(&self) -> Result<OwnedTransactionLease, Error>

Acquire the only active stream lease for this transaction.

fn commit(&self) -> Result<OwnedTransactionSessionStatus, Error>

Commit once after every active lease has released as committable.

fn rollback(&self) -> Result<OwnedTransactionSessionStatus, Error>

Roll back once, including the conservative must abort path.