Struct ConnectionPool

pub struct ConnectionPool { /* private fields */ }

连接池管理器

Implementations

impl ConnectionPool

pub fn new(config: ConnectionPoolConfig) -> Self

创建新的连接池

pub async fn get_connection( &self, addr: &str, identify_config: Option<IdentifyConfig>, auth_secret: Option<String>, ) -> Result<Arc<Connection>>

获取连接

pub fn start_cleanup_task(pool: Arc<ConnectionPool>)

启动连接池清理任务

pub fn start_health_check_task(pool: Arc<ConnectionPool>)

启动健康检查任务

pub async fn cleanup_idle_connections(&self)

清理空闲连接

pub async fn check_connections_health(&self)

检查连接健康状态

pub fn get_stats(&self) -> ConnectionPoolStats

获取连接池统计信息

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.