Struct ConnectionPool 

pub struct ConnectionPool<T: PooledConnection + Clone> { /* private fields */ }

Advanced connection pool implementation with monitoring and load balancing

Implementations

impl<T: PooledConnection + Clone> ConnectionPool<T>

pub async fn new( config: PoolConfig, factory: Arc<dyn ConnectionFactory<T>>, ) -> Result<Self>

Create a new advanced connection pool with monitoring and circuit breaker

pub async fn get_connection(&self) -> Result<PooledConnectionHandle<T>>

Get a connection from the pool with advanced load balancing and monitoring

pub async fn status(&self) -> PoolStatus

Get comprehensive pool status with advanced metrics

pub async fn stats(&self) -> PoolStats

Get pool statistics

impl<T: PooledConnection + Clone> ConnectionPool<T>

Helper for creating connection pools from stream config

pub async fn new_from_config( config: &StreamConfig, factory: Arc<dyn ConnectionFactory<T>>, ) -> Result<Self>

Create a connection pool from stream configuration

pub async fn health_check(&self) -> PoolStatus

Health check with enhanced status

pub async fn get_detailed_metrics(&self) -> DetailedPoolMetrics

Get detailed pool metrics for monitoring

pub async fn reset_statistics(&self)

Reset pool statistics

pub async fn resize(&self, new_size: usize) -> Result<()>

Force resize the pool

pub async fn new_with_failover( config: PoolConfig, primary_factory: Arc<dyn ConnectionFactory<T>>, secondary_factory: Arc<dyn ConnectionFactory<T>>, failover_config: FailoverConfig, ) -> Result<Self>

Create a connection pool with failover support

pub async fn get_health_statistics(&self) -> OverallHealthStatistics

Get health statistics from the health monitor

pub async fn get_reconnection_statistics(&self) -> ReconnectStatistics

Get reconnection statistics

pub async fn get_failover_statistics(&self) -> Option<FailoverStatistics>

Get failover statistics if failover is enabled

pub async fn register_failure_callback<F>(&self, callback: F)

where F: Fn(String, String, u32) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync + 'static,

Register a connection failure callback for automatic reconnection

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

Manually trigger failover (if configured)

pub fn has_failover(&self) -> bool

Check if the pool has failover configured

pub async fn get_unhealthy_connections(&self) -> Vec<String>

Get unhealthy connections from health monitor

pub fn subscribe_health_events(&self) -> Receiver<HealthEvent>

Subscribe to health monitoring events

pub fn subscribe_reconnect_events(&self) -> Receiver<ReconnectEvent>

Subscribe to reconnection events