Struct Timing 

pub struct Timing {
    pub heartbeat_interval_ms: u64,
    pub heartbeat_suppress_ms: u64,
    pub disconnect_timeout_ms: u64,
    pub registration_timeout_ms: u64,
    pub peer_dead_threshold: u32,
}

Per-node timing policy.

The constants above are the defaults, chosen for a LAN-attached replay rig where a node quiet for 800 ms really has died. A wobbling link — an SSH tunnel to a robot on cellular, a laptop roaming between access points — has one-second hiccups that must not be read as a death.

A node carries its own Timing and tells the coordinator about it when it joins, so the two sides agree on how patient to be with each other.

The fields are interdependent. Timing::validate checks the relationships that the rest of the system relies on.

Fields

heartbeat_interval_ms: u64

How often this node sends a heartbeat to keep its connection alive.

heartbeat_suppress_ms: u64

A heartbeat is skipped if real data was sent within this window.

disconnect_timeout_ms: u64

How long the coordinator waits with no message before declaring this node gone, and how long this node waits for heartbeat echoes before declaring the coordinator gone.

registration_timeout_ms: u64

How long to wait for a coordinator before giving up on registration.

peer_dead_threshold: u32

Consecutive peer ping failures before declaring that peer dead.

Implementations

impl Timing

pub fn wan() -> Self

Timing for a link that is expected to wobble: off-LAN, tunnelled, wireless, or otherwise not under your control.

Roughly 5× more patient than the default. Dead-node detection takes about 10 seconds.

pub fn validate(&self) -> Result<()>

Check the relationships the rest of the system relies on.

Called when a node is built, so a bad custom Timing fails loudly at startup with a concrete configuration error.

pub fn heartbeat_interval(&self) -> Duration

pub fn heartbeat_suppress(&self) -> Duration

pub fn disconnect_timeout(&self) -> Duration

pub fn registration_timeout(&self) -> Duration

Trait Implementations

impl Clone for Timing

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Timing

impl Debug for Timing

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

Formats the value using the given formatter.

impl Default for Timing

fn default() -> Self

Returns the “default value” for a type.

impl Eq for Timing

impl PartialEq for Timing

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Timing