Struct Transaction 

pub struct Transaction(/* private fields */);

A unit of work shared by every backend it touches. Commit runs backend by backend, so it’s atomic per backend, not across them: if one fails part-way, the backends before it stay committed and the rest roll back.

Implementations

impl Transaction

pub fn wrap(&self, vista: &Vista) -> Vista

vista, reading and writing through this transaction. Its shell is rebound now; a shell that can’t rebind errors at the wrapped Vista’s first use, not here. Every Vista the result returns (get_ref targets) is wrapped too.

The participants the rebind joins are the ones its writes are credited to, for committed_before_failure: a shell joins in rebind, not at its first statement.

pub fn resolver(&self, base: Arc<dyn VistaResolver>) -> Arc<dyn VistaResolver>

base, with every Vista it resolves, or adopts, wrapped in this transaction.

impl Transaction

pub fn new() -> Transaction

pub fn downgrade(&self) -> WeakTransaction

pub fn same(&self, other: &Transaction) -> bool

pub fn participant<P: TxParticipant>( &self, key: TxKey, make: impl FnOnce() -> P, ) -> Result<Arc<P>>

The participant for key, made by make on first use; later calls return the same Arc. Err if the one stored under key is another type.

pub fn defer( &self, after: Box<dyn FnOnce() -> BoxFuture<'static, Result<()>> + Send>, )

Run after a successful commit, in order. Dropped on rollback.

pub fn note_written(&self, table: &str)

Record a table written through this transaction (the written-tables report).

pub fn unprotected(&self) -> Vec<String>

The tables written directly so far (Committed::unprotected), also after a rollback or a failed commit.

pub fn committed_before_failure(err: &VantageError) -> Vec<String>

The tables whose participants committed before the failure, in commit order, read from an error commit returned. Empty for any other error, and when nothing had committed.

pub fn is_finished(&self) -> bool

pub fn check_open(&self) -> Result<()>

pub async fn commit(&self) -> Result<Committed>

Commits participants in join order. On the first failure the rest are rolled back and the error returned; the ones already committed stay committed, and the error names their tables (committed_before_failure). Deferred closures run only after a full success, and their failures are logged, not returned.

pub async fn rollback(&self) -> Result<()>

Trait Implementations

impl Clone for Transaction

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Transaction

fn default() -> Self

Returns the “default value” for a type.