Struct PgPool 

pub struct PgPool { /* private fields */ }

Example

let config = PoolConfig::new("localhost", 5432, "user", "db")
    .password("secret")
    .max_connections(20);
let pool = PgPool::connect(config).await?;
// Get a connection from the pool
let mut conn = pool.acquire().await?;
conn.simple_query("SELECT 1").await?;

Implementations

impl PgPool

pub async fn from_config() -> PgResult<Self>

Create a pool from qail.toml (loads and parses automatically).

Example

let pool = PgPool::from_config().await?;

pub async fn connect(config: PoolConfig) -> PgResult<Self>

Create a new connection pool.

pub async fn acquire(&self) -> PgResult<PooledConnection>

Acquire a connection from the pool.

pub async fn acquire_with_rls( &self, ctx: RlsContext, ) -> PgResult<PooledConnection>

Acquire a connection with RLS context pre-configured.

Sets PostgreSQL session variables for tenant isolation before returning the connection. When the connection is dropped, it automatically clears the RLS context before returning to the pool.

Example

use qail_core::rls::RlsContext;

let mut conn = pool.acquire_with_rls(
    RlsContext::operator("550e8400-e29b-41d4-a716-446655440000")
).await?;
// All queries through `conn` are now scoped to this operator

pub async fn idle_count(&self) -> usize

Get the current number of idle connections.

pub fn active_count(&self) -> usize

Get the number of connections currently in use.

pub fn max_connections(&self) -> usize

Get the maximum number of connections.

pub async fn stats(&self) -> PoolStats

Get comprehensive pool statistics.

pub fn is_closed(&self) -> bool

Check if the pool is closed.

pub async fn close(&self)

Close the pool gracefully.

Trait Implementations

impl Clone for PgPool

fn clone(&self) -> PgPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.