Struct KeepaliveManager 

pub struct KeepaliveManager { /* private fields */ }

Manages keepalive timing, miss counting, and adaptive interval adjustment.

Implementations

impl KeepaliveManager

pub fn new(config: KeepaliveConfig) -> Self

Create a new keepalive manager with the given config.

pub fn from_preset(preset: KeepalivePreset) -> Self

Create with a preset.

pub fn check(&mut self) -> KeepaliveAction

Check what keepalive action to take right now.

Call this periodically (e.g. every second) in your main loop.

loop {
    match manager.check() {
        KeepaliveAction::SendPing       => conn.ping().await?,
        KeepaliveAction::PongTimeout    => manager.record_pong_missed(),
        KeepaliveAction::ConnectionDead => break, // reconnect
        KeepaliveAction::Idle           => {}
    }
    tokio::time::sleep(Duration::from_secs(1)).await;
}

pub fn should_send_keepalive(&self) -> bool

Returns true if a keepalive ping should be sent now.

pub fn record_keepalive_sent(&mut self)

Record that a keepalive ping was sent.

pub fn record_pong_received(&mut self)

Record that a pong was received.

Resets miss counter, updates RTT estimate, adjusts adaptive interval.

pub fn record_pong_missed(&mut self)

Record a missed pong (called after KeepaliveAction::PongTimeout).

pub fn record_activity(&mut self)

Record any activity (data received) — resets the keepalive timer.

pub fn reset_misses(&mut self)

Reset miss counter (e.g. after reconnect).

pub fn srtt(&self) -> Option<Duration>

Returns the current smoothed RTT from keepalive pings.

pub fn current_interval(&self) -> Duration

Returns the current effective keepalive interval (adaptive or configured).

pub fn missed_pongs(&self) -> u32

Returns the number of consecutive missed pongs.

pub fn is_waiting_for_pong(&self) -> bool

Returns true if we are waiting for a pong right now.

pub fn is_dead(&self) -> bool

Returns true if the connection is considered dead (too many missed pongs).

pub fn total_sent(&self) -> u64

Returns total keepalives sent.

pub fn total_pongs(&self) -> u64

Returns total pongs received.

pub fn last_pong(&self) -> Option<Instant>

Returns when the last pong was received.

pub fn config(&self) -> &KeepaliveConfig

Returns a reference to the config.