Struct ConnectionPool 

pub struct ConnectionPool {
    pub config: PoolConfig,
    pub connections: Arc<Mutex<HashMap<String, ConnectionHandle>>>,
    pub semaphore: Arc<Semaphore>,
    pub wait_queue: Arc<Mutex<Vec<Arc<Notify>>>>,
    pub stats: Arc<RwLock<PoolStats>>,
    pub health_checker: Arc<Mutex<ConnectionHealthChecker>>,
    pub is_running: Arc<Mutex<bool>>,
}

Connection pool with advanced management

Fields

config: PoolConfig

connections: Arc<Mutex<HashMap<String, ConnectionHandle>>>

semaphore: Arc<Semaphore>

wait_queue: Arc<Mutex<Vec<Arc<Notify>>>>

stats: Arc<RwLock<PoolStats>>

health_checker: Arc<Mutex<ConnectionHealthChecker>>

is_running: Arc<Mutex<bool>>

Implementations

impl ConnectionPool

pub fn new(config: PoolConfig) -> Self

Create a new connection pool

pub async fn start(&self) -> Result<(), String>

Start the connection pool

pub async fn stop(&self) -> Result<(), String>

Stop the connection pool

pub async fn get_connection(&self) -> Result<ConnectionHandle, String>

Get a connection from the pool

pub async fn release_connection(&self, handle: ConnectionHandle)

Release a connection back to the pool

async fn find_or_create_connection(&self) -> Result<ConnectionHandle, String>

Find or create a healthy connection

async fn start_health_monitoring(&self)

Start health monitoring

async fn start_connection_cleanup(&self)

Start connection cleanup

async fn initialize_min_connections(&self)

Initialize minimum connections

async fn check_connection_health(&self) -> Result<(), String>

Check connection health

async fn cleanup_stale_connections(&self) -> usize

Cleanup stale connections

pub async fn get_stats(&self) -> PoolStats

Get pool statistics

pub async fn get_active_count(&self) -> usize

Get active connection count

pub async fn get_healthy_count(&self) -> usize

Get healthy connection count

pub async fn is_running(&self) -> bool

Check if pool is running

impl ConnectionPool

Utility functions for connection pooling

pub fn default_pool() -> Self

Create a connection pool with default configuration

pub fn high_performance_pool() -> Self

Create a high-performance pool

pub fn conservative_pool() -> Self

Create a conservative pool

pub fn calculate_optimal_pool_size() -> usize

Calculate optimal pool size based on system resources

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.