Struct TransactionRunner

pub struct TransactionRunner<'a, H = (), P = NativeRetryPolicy> { /* private fields */ }

Builder for a transactional run, returned by Database::runner.

It assembles the RunnerHooks and the RetryPolicy of a single call to run: no hooks and NativeRetryPolicy by default. Both are borrowed, so the same hooks and policy can be reused across runs (mind MetricsHooks, which times the run from its own construction).

db.runner()
    .run(|trx, _| async move {
        trx.set(b"key", b"value");
        Ok::<_, FdbBindingError>(())
    })
    .await

Implementations

impl<'a, H, P> TransactionRunner<'a, H, P>

pub fn hooks<H2>(self, hooks: &'a H2) -> TransactionRunner<'a, H2, P>

Observes the run with hooks, replacing any hooks set before.

Stack several of them with a tuple: .hooks(&(first, second)).

pub fn retry_policy<P2>(self, policy: &'a P2) -> TransactionRunner<'a, H, P2>

Decides the retries with policy instead of NativeRetryPolicy.

pub async fn run<F, Fut, T, E>(self, closure: F) -> Result<T, E>

where F: Fn(RetryableTransaction, MaybeCommitted) -> Fut, Fut: Future<Output = Result<T, E>>, E: RetryableError, H: RunnerHooks, P: RetryPolicy<E>,

Runs closure in a transaction, retrying it until it commits or the error is fatal.

See Database::run for the semantics of the closure, its error type and the retries.