Struct akd::storage::transaction::Transaction

pub struct Transaction { /* private fields */ }

Represents an in-memory transaction, keeping a mutable state of the changes. When you “commit” this transaction, you return the collection of values which need to be written to the storage layer including all mutations. Rollback simply empties the transaction state.

Implementations

impl Transaction

pub fn new() -> Self

Instantiate a new transaction instance

impl Transaction

pub async fn log_metrics(&self, level: Level)

Log metrics about the current transaction instance. Metrics will be cleared after log call

pub async fn begin_transaction(&self) -> bool

Start a transaction in the storage layer

pub async fn commit_transaction(&self) -> Result<Vec<DbRecord>, StorageError>

Commit a transaction in the storage layer

pub async fn rollback_transaction(&self) -> Result<(), StorageError>

Rollback a transaction

pub async fn is_transaction_active(&self) -> bool

Retrieve a flag determining if there is a transaction active

pub async fn get<St: Storable>(&self, key: &St::Key) -> Option<DbRecord>

Hit test the current transaction to see if it is currently active

pub async fn set(&self, record: &DbRecord)

Set a value in the transaction to be committed at transaction commit time

Trait Implementations

impl Debug for Transaction

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

Formats the value using the given formatter.

impl Default for Transaction

fn default() -> Self

Returns the “default value” for a type.

impl Send for Transaction

impl Sync for Transaction