Struct Layer 

pub struct Layer<E> { /* private fields */ }

A tower_layer::Layer that adds request-scoped PostgreSQL transaction management to an axum router.

Insert this layer into your router to enable the Tx extractor. Each request will have its own transaction, which is committed automatically when the response is sent.

Examples

With bb8-postgres:

use axum::Router;
use bb8_postgres::{PostgresConnectionManager, tokio_postgres::NoTls};

async fn example() {
    let manager = PostgresConnectionManager::new("host=localhost user=postgres", NoTls);
    let pool = bb8_postgres::bb8::Pool::builder().build(manager).await.unwrap();
    let router = Router::new().layer(axum_postgres_tx::layer::Layer::from(pool));
}

With deadpool-postgres:

use axum::Router;
use deadpool_postgres::{Config, Runtime};
use tokio_postgres::NoTls;

async fn example() {
    let mut cfg = Config::new();
    cfg.dbname = Some("postgres".to_string());
    let pool = cfg.create_pool(Some(Runtime::Tokio1), NoTls).unwrap();
    let router = Router::new().layer(axum_postgres_tx::layer::Layer::from(pool));
}

Trait Implementations

impl<E> Clone for Layer<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<Pool<PostgresConnectionManager<NoTls>>> for Layer<Error>

fn from(value: Pool<PostgresConnectionManager<NoTls>>) -> Self

Converts to this type from the input type.

impl<S, E> Layer<S> for Layer<E>

type Service = Service<S, E>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.