Struct KeepAliveManager

pub struct KeepAliveManager {
    pub ping_interval: Duration,
    /* private fields */
}

Keep-alive manager to maintain active connections and detect dead peers

Fields

ping_interval: Duration

Interval for sending ping messages

Implementations

impl KeepAliveManager

pub fn new() -> Self

Create a new keep-alive manager with default settings

pub fn with_settings(ping_interval: Duration, dead_timeout: Duration) -> Self

Create a new keep-alive manager with custom settings

pub fn update_send(&mut self)

Update last send time

pub fn update_recv(&mut self)

Update last receive time

pub fn should_ping(&self) -> bool

Check if we need to send a ping to keep the connection alive

pub fn ping_interval(&self) -> Duration

Get the ping interval duration

pub fn is_connection_dead(&self) -> bool

Check if the connection is considered dead (no messages received)

pub fn time_since_last_recv(&self) -> Duration

Get time since last received message

pub fn build_ping_message() -> Message

Build a ping message for keep-alive

pub fn process_message(&mut self, msg: &Message) -> bool

Process an incoming message, update received timestamp if it’s not a pong Returns true if the message was a pong response to our ping

Trait Implementations

impl Debug for KeepAliveManager

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

Formats the value using the given formatter.

impl Default for KeepAliveManager

fn default() -> Self

Returns the “default value” for a type.