Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

LRU 连接池

Implementations

impl ConnectionPool

pub fn new(config: PoolConfig) -> Self

pub fn config(&self) -> &PoolConfig

获取配置

pub async fn admit( &self, connection_id: impl Into<String>, now_ms: i64, ) -> AdmitResult

尝试将连接加入池中。

• 若已存在，返回 AlreadyExists
• 若池已满，淘汰 LRU 末尾连接后接纳
• 否则接纳

pub async fn remove(&self, connection_id: &str) -> Option<PooledConnection>

移除连接

pub async fn touch(&self, connection_id: &str, now_ms: i64) -> bool

更新连接活跃时间（移到 LRU 头部）

pub async fn record_sent(&self, connection_id: &str) -> bool

记录发送消息

pub async fn record_received(&self, connection_id: &str) -> bool

记录接收消息

pub async fn get(&self, connection_id: &str) -> Option<PooledConnection>

获取连接

pub async fn count(&self) -> usize

当前连接数

pub async fn is_full(&self) -> bool

是否已满

pub async fn find_by_user(&self, user_id: i64) -> Vec<PooledConnection>

按用户 ID 查询连接

pub async fn evict_idle(&self, idle_threshold_ms: i64, now_ms: i64) -> usize

清理空闲超过指定时长的连接，返回被清理的数量

pub async fn clear(&self)

清空连接池

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

获取 LRU 顺序的连接 ID 列表（最近活跃在前）

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.