Struct HeartbeatTracker 

pub struct HeartbeatTracker { /* private fields */ }

多连接心跳跟踪器

Implementations

impl HeartbeatTracker

pub fn new(config: HeartbeatConfig) -> Self

pub fn config(&self) -> &HeartbeatConfig

获取配置

pub async fn register(&self, connection_id: impl Into<String>)

注册一个连接（若已存在则保留原状态）

pub async fn register_new(&self, connection_id: impl Into<String>)

注册一个连接（确保新建状态）

pub async fn unregister(&self, connection_id: &str) -> Option<HeartbeatState>

注销连接

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

记录发送 Ping

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

记录收到 Pong

pub async fn check_timeouts(&self, now_ms: i64) -> (Vec<String>, Vec<String>)

检查所有连接的超时状态，返回 (本次新增超时的连接列表, 本次被判定为失活的连接列表)

pub async fn state(&self, connection_id: &str) -> Option<HeartbeatState>

获取指定连接的心跳状态

pub async fn count(&self) -> usize

当前跟踪的连接数

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

获取所有失活连接的 ID

pub async fn purge_dead(&self) -> usize

清理所有失活连接，返回被清理的数量

pub async fn rtts(&self) -> Vec<(String, i64)>

获取所有连接的 RTT（毫秒），仅返回有有效 RTT 的

Trait Implementations

impl Debug for HeartbeatTracker

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

Formats the value using the given formatter.