Struct ConnectionPoolManager 

pub struct ConnectionPoolManager { /* private fields */ }

Connection pool manager with mode awareness

Manages connection leases across multiple nodes with support for different pooling modes (session, transaction, statement).

Implementations

impl ConnectionPoolManager

pub fn new(config: PoolModeConfig) -> Self

Create a new connection pool manager

pub async fn add_node(&self, node: &NodeEndpoint)

Add a node to the pool manager

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

Remove a node from the pool manager

pub async fn acquire( &self, client_id: ClientId, node_id: &NodeId, ) -> Result<ConnectionLease>

Acquire a connection lease

Arguments

• client_id - Client identifier
• node_id - Target node

Returns

A connection lease for the specified node

pub async fn acquire_with_mode( &self, client_id: ClientId, node_id: &NodeId, mode: PoolingMode, ) -> Result<ConnectionLease>

Acquire a connection lease with specific mode

pub async fn release(&self, lease: ConnectionLease)

Release a connection lease

The connection will be reset and returned to the pool.

pub async fn release_and_close(&self, lease: ConnectionLease)

Release a connection lease and close it (don’t return to pool)

pub fn on_statement_complete( &self, lease: &mut ConnectionLease, sql: &str, ) -> LeaseAction

Process a completed statement and determine if connection should be released

Arguments

• lease - The connection lease (mutable)
• sql - The SQL that was executed

Returns

The action to take with the connection

pub async fn get_stats(&self) -> PoolStats

Get pool statistics

pub fn metrics(&self) -> &PoolModeMetrics

Get metrics

pub fn config(&self) -> &PoolModeConfig

Get configuration

pub fn default_mode(&self) -> PoolingMode

Get default pooling mode

pub fn has_active_lease(&self, client_id: &ClientId) -> bool

Check if a client has an active lease

pub fn active_lease_count(&self) -> usize

Get the number of active leases

pub async fn close_all(&self)

Close all connections in all pools

pub async fn evict_idle(&self)

Evict idle connections from all pools

Trait Implementations

impl Debug for ConnectionPoolManager

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

Formats the value using the given formatter.