Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing QUIC connections

Implementations

impl ConnectionPool

pub fn new(host: impl Into<String>, port: u16, max_size: usize) -> Self

Create a new connection pool.

Panics

Panics if max_size is 0. A connection pool must have at least one connection slot to function properly. (Gap #18: CWE-400, CWE-835)

pub fn from_dsn(dsn: &str) -> Result<Self>

Build a pool from a DSN string using the default max size (16).

Errors

Returns an error if the DSN is invalid.

pub fn from_dsn_with_size(dsn: &str, max_size: usize) -> Result<Self>

Build a pool from a DSN string with an explicit max size.

Panics

Panics if max_size is 0 (a pool needs at least one slot).

Errors

Returns an error if the DSN is invalid.

pub fn from_client(client: Client, max_size: usize) -> Self

Build a pool from a pre-configured Client.

Panics

Panics if max_size is 0.

pub fn skip_verify(self, skip: bool) -> Self

Configure to skip TLS verification

pub fn page_size(self, size: usize) -> Self

Set page size for queries

pub fn username(self, username: impl Into<String>) -> Self

Set the authentication username used for new pooled connections.

pub fn password(self, password: impl Into<String>) -> Self

Set the authentication password used for new pooled connections.

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

Acquire a connection from the pool

Returns a healthy connection from the pool, or creates a new one if needed. Stale connections (those where the underlying QUIC connection has been closed) are automatically discarded during acquisition.

pub async fn batch_exec(&self, stmts: &[Statement]) -> Result<()>

Execute statements as a single batch in one transaction, with the default retry policy. Acquires one connection from the pool.

Errors

Returns the first failing statement’s error (the transaction is rolled back). An empty slice is a no-op.

pub async fn pipeline_exec( self: &Arc<Self>, stmts: &[Statement], chunk_size: usize, max_workers: usize, ) -> Result<()>

Execute statements concurrently in chunks, each chunk a single transaction (via batch_exec with retry). At most max_workers chunks run at once. The first error stops dispatching new chunks; in-flight chunks complete. chunk_size/max_workers of 0 use the defaults (100 / 8).

Errors

Returns the first error recorded across all chunks.

pub async fn size(&self) -> usize

Get current pool size

pub fn max_size(&self) -> usize

Get the maximum pool size