qail-pg 0.26.5

Fastest async PostgreSQL driver - AST to wire protocol, optional io_uring on Linux
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

//! PostgreSQL Connection Pool
//!
//! Provides connection pooling with prepared-statement caching, RLS pipelining,
//! churn protection, and hot-statement cross-connection sharing.

mod churn;
mod config;
mod connection;
mod fetch;
mod gss;
mod lifecycle;
#[cfg(test)]
mod tests;

use crate::driver::PgResult;
use std::future::Future;
use std::pin::Pin;

/// Boxed async return type for scoped pool helpers (`with_rls`, `with_tenant`, etc.).
pub type ScopedPoolFuture<'a, T> = Pin<Box<dyn Future<Output = PgResult<T>> + Send + 'a>>;

/// Helper to box async closures for scoped pool helpers.
///
/// This avoids writing `Box::pin(...)` directly at every callsite.
///
/// # Example
/// ```ignore
/// use qail_pg::scope;
///
/// let users = pool
///     .with_tenant(tenant_id, |conn| scope(async move {
///         conn.fetch_all_uncached(&cmd).await
///     }))
///     .await?;
/// ```
#[inline]
pub fn scope<'a, T, Fut>(fut: Fut) -> ScopedPoolFuture<'a, T>
where
    Fut: Future<Output = PgResult<T>> + Send + 'a,
{
    Box::pin(fut)
}

// ── Public API ──────────────────────────────────────────────────────
pub use churn::PoolStats;
pub use config::PoolConfig;
pub use connection::PooledConnection;
pub use lifecycle::{PgPool, spawn_pool_maintenance};

// ── Crate-internal ──────────────────────────────────────────────────
pub(crate) use config::apply_url_query_params;