Struct KeepalivePolicy 

pub struct KeepalivePolicy {
    pub interval: Duration,
    pub timeout: Option<Duration>,
    pub max_missed: u32,
}

How often to ping, how long to wait for each pong, and how many consecutive misses mean the connection is dead.

Fields

interval: Duration

Delay between pings. Duration::ZERO disables pinging, matching how OCPP’s WebSocketPingInterval reads a 0 value.

timeout: Option<Duration>

How long to wait for each pong before counting it as missed. None uses the client’s own request timeout, which is what almost every caller wants - a pong that takes longer than a CALL is already a broken link.

max_missed: u32

Consecutive missed pongs before the connection is treated as dead and redialled. 0 is treated as 1. Defaults to 2 so a single dropped frame - or a peer that answers one ping oddly - doesn’t cost a reconnect.

Implementations

impl KeepalivePolicy

pub fn every(interval: Duration) -> Self

A policy pinging every interval, with default timeout and miss tolerance.

Trait Implementations

impl Clone for KeepalivePolicy

fn clone(&self) -> KeepalivePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for KeepalivePolicy

impl Debug for KeepalivePolicy

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

Formats the value using the given formatter.

impl Default for KeepalivePolicy

fn default() -> Self

Returns the “default value” for a type.

impl Eq for KeepalivePolicy

impl PartialEq for KeepalivePolicy

fn eq(&self, other: &KeepalivePolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for KeepalivePolicy