Struct AsyncPool 

pub struct AsyncPool { /* private fields */ }

A pool of N AsyncConns for parallel PostgreSQL backend utilization. Detects dead connections and replaces them automatically.

Implementations

impl AsyncPool

pub async fn connect( addr: &str, user: &str, password: &str, database: &str, size: usize, ) -> Result<Arc<Self>, PgWireError>

Create a pool of size AsyncConns, each with its own TCP connection.

pub async fn connect_with_tls( addr: &str, user: &str, password: &str, database: &str, size: usize, tls_mode: TlsMode, ) -> Result<Arc<Self>, PgWireError>

Create a pool with an explicit TLS mode.

pub async fn get_async(&self) -> Arc<AsyncConn>

Get the next alive AsyncConn via round-robin.

pub fn size(&self) -> usize

Number of connections in the pool.

pub async fn alive_count(&self) -> usize

Number of alive connections.

pub async fn close(&self) -> Result<(), PgWireError>

Close all connections in the pool by sending Terminate on each and waiting for the writer/reader tasks to exit. Idempotent: dead slots are skipped.

pub async fn exec_transaction( &self, setup_sql: &str, query_sql: &str, params: &[Option<&[u8]>], param_oids: &[u32], ) -> Result<Vec<RawRow>, PgWireError>

Execute a pipelined transaction on the next available connection.

pub async fn exec_query( &self, sql: &str, params: &[Option<&[u8]>], param_oids: &[u32], ) -> Result<Vec<RawRow>, PgWireError>

Execute a parameterized query on the next available connection.

pub async fn exec_query_with_formats( &self, sql: &str, params: &[Option<&[u8]>], param_oids: &[u32], param_formats: &[FormatCode], result_formats: &[FormatCode], ) -> Result<Vec<RawRow>, PgWireError>

Execute a parameterized query with explicit per-param and per-result format codes on the next available connection.

Trait Implementations

impl Debug for AsyncPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.