Struct TransactionMiddleware 

pub struct TransactionMiddleware<DB: Database, E = Error> { /* private fields */ }

This middleware adds a lazily-initialised transaction to the request extensions. The first time the Tx extractor is used on a request, a connection is acquired from the configured sqlx::Pool and a transaction is started on it. The same transaction will be returned for subsequent uses of Tx on the same request. The inner service is then called as normal. Once the inner service responds, the transaction is committed or rolled back depending on the status code of the response.

Implementations

impl<DB: Database> TransactionMiddleware<DB>

pub fn new(pool: Pool<DB>) -> Self

pub fn new_with_error<E>(pool: Pool<DB>) -> TransactionMiddleware<DB, E>

Construct a new layer with a specific error type.

Trait Implementations

impl<DB: Clone + Database, E: Clone> Clone for TransactionMiddleware<DB, E>

fn clone(&self) -> TransactionMiddleware<DB, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, B, DB, E> Transform<S, ServiceRequest> for TransactionMiddleware<DB, E>

where S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error> + 'static, S::Future: 'static, B: MessageBody + 'static, DB: Database + 'static, E: From<Error> + ResponseError + 'static,

type Response = ServiceResponse<B>

Responses produced by the service.

type Error = Error

Errors produced by the service.

type Transform = InnerTransactionMiddleware<S, DB, E>

The TransformService value created by this factory

type InitError = ()

Errors produced while building a transform service.

type Future = Ready<Result<<TransactionMiddleware<DB, E> as Transform<S, ServiceRequest>>::Transform, <TransactionMiddleware<DB, E> as Transform<S, ServiceRequest>>::InitError>>

The future response value.

fn new_transform(&self, service: S) -> Self::Future

Creates and returns a new Transform component, asynchronously