Struct DieselBlockingPool 

pub struct DieselBlockingPool { /* private fields */ }

Cloneable (Arc-backed) handle around a Diesel r2d2 pool.

Implementations

impl DieselBlockingPool

pub fn new(database_url: &str, max_size: u32) -> Result<Self, DataError>

Build the pool. Connection establishment happens lazily per checkout.

pub async fn run<R, F>(&self, job: F) -> Result<R, DataError>

where F: FnOnce(&mut DieselConn) -> Result<R, Error> + Send + 'static, R: Send + 'static,

Run job on the blocking pool. Pool checkout AND the queries execute off the async worker; the worker only awaits the join handle.

pub async fn ping(&self) -> Result<(), DataError>

Health ping: a pooled checkout on the blocking pool. r2d2 validates connections on checkout, so success means the database answered.

pub async fn transaction<R, F>(&self, job: F) -> Result<R, DataError>

where F: FnOnce(&mut DieselConn) -> Result<R, Error> + Send + 'static, R: Send + 'static,

Run job inside one Diesel transaction on the blocking pool: commit on Ok, rollback on Err — the closure-scoped equivalent of #[Transactional] for the sync ecosystem.

Trait Implementations

impl Clone for DieselBlockingPool

fn clone(&self) -> DieselBlockingPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.