Struct HeartbeatState 

pub struct HeartbeatState {
    pub connection_id: String,
    pub last_ping_at: Option<i64>,
    pub last_pong_at: Option<i64>,
    pub missed_count: u32,
    pub total_pings: u64,
    pub total_pongs: u64,
    pub is_dead: bool,
}

单连接的心跳状态

Fields

connection_id: String

连接 ID

last_ping_at: Option<i64>

上次发送 Ping 的时间戳（毫秒），None 表示尚未发送

last_pong_at: Option<i64>

上次收到 Pong 的时间戳（毫秒）

missed_count: u32

连续未收到 Pong 的次数

total_pings: u64

总共发送的 Ping 次数

total_pongs: u64

总共收到的 Pong 次数

is_dead: bool

是否被判定为失活

Implementations

impl HeartbeatState

pub fn new(connection_id: impl Into<String>) -> Self

pub fn record_ping(&mut self, now_ms: i64)

记录发送了一次 Ping

pub fn record_pong(&mut self, now_ms: i64) -> bool

记录收到了一次 Pong。返回是否清除了未应答计数。

pub fn check_timeout(&mut self, now_ms: i64, config: &HeartbeatConfig) -> bool

检查是否超时未收到 Pong。 返回 true 表示本次检查新增了一次未应答。

pub fn rtt_ms(&self) -> Option<i64>

当前 RTT 估计（毫秒）。需要 last_ping 和 last_pong 都存在。

pub fn awaiting_pong(&self) -> bool

是否正在等待 Pong 应答

Trait Implementations

impl Clone for HeartbeatState

fn clone(&self) -> HeartbeatState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HeartbeatState

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

Formats the value using the given formatter.