Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection Pool Manager

Implementations

impl ConnectionPool

pub fn new(config: PoolConfig) -> Self

Create a new connection pool

pub fn with_backend_template(self, template: BackendConfig) -> Self

Attach a backend-connection template. With a template and a per-node endpoint (set via add_node_with_endpoint), the pool opens real PG connections via crate::backend::BackendClient. Without a template the pool stays in skeleton mode — existing tests that use synthetic NodeIds keep passing unchanged.

pub async fn add_node(&self, node_id: NodeId)

Add a node to the pool (skeleton mode — no real backend).

pub async fn add_node_with_endpoint( &self, node_id: NodeId, host: impl Into<String>, port: u16, )

Add a node with endpoint info. When combined with with_backend_template, create_connection opens a live BackendClient against the given host:port.

pub async fn remove_node(&self, node_id: &NodeId)

Remove a node from the pool

pub async fn get_connection(&self, node_id: &NodeId) -> Result<PooledConnection>

Get a connection from the pool

pub async fn return_connection(&self, conn: PooledConnection)

Return a connection to the pool

pub async fn close_connection(&self, conn: PooledConnection)

Close a connection (don’t return to pool)

pub async fn validate_connection(&self, conn: &PooledConnection) -> Result<bool>

Validate a connection.

When a live backend client is attached, runs SELECT 1. When no client is attached, falls back to the pre-T0-TR1 state check — useful for tests that don’t stand up a real backend.

pub async fn run_reset_query( &self, conn: &mut PooledConnection, query: &str, ) -> Result<()>

Run a reset query on a connection (if live) before returning it to the pool. Used by pool-modes release for Transaction and Statement modes.

pub async fn close_all(&self) -> Result<()>

Close all connections

pub async fn evict_idle(&self)

Evict idle connections that have exceeded idle timeout

pub async fn total_connections(&self) -> usize

Get total connections

pub async fn active_connections(&self) -> usize

Get active connections

pub async fn metrics(&self) -> PoolMetrics

Get pool metrics

pub async fn node_stats(&self, node_id: &NodeId) -> Option<NodePoolStats>

Get per-node statistics