Struct HostConnectionPool 

pub struct HostConnectionPool {
    pub host: String,
    pub available: Arc<Mutex<VecDeque<Arc<ManagedConnection>>>>,
    pub in_use: Arc<RwLock<HashMap<String, Arc<ManagedConnection>>>>,
    pub config: ConnectionConfig,
    pub pool_stats: Arc<RwLock<PoolStats>>,
}

Connection pool manager for a specific host

Fields

host: String

Host this pool manages

available: Arc<Mutex<VecDeque<Arc<ManagedConnection>>>>

Available connections

in_use: Arc<RwLock<HashMap<String, Arc<ManagedConnection>>>>

Currently in-use connections

config: ConnectionConfig

Pool configuration

pool_stats: Arc<RwLock<PoolStats>>

Pool-level statistics

Implementations

impl HostConnectionPool

pub fn new(host: String, config: ConnectionConfig) -> Self

Create new connection pool for host

pub async fn get_connection(&self) -> Result<Arc<ManagedConnection>, Error>

Get a connection from the pool or create a new one

Errors

Returns an error if a new connection cannot be created when the pool is empty or when all existing connections are unhealthy.

pub async fn return_connection(&self, conn: Arc<ManagedConnection>)

Return connection to available pool

pub async fn cleanup_connections(&self)

Cleanup idle and unhealthy connections

pub async fn get_stats(&self) -> PoolStatistics

Get pool statistics

Trait Implementations

impl Debug for HostConnectionPool

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

Formats the value using the given formatter.