Struct Liveness 

pub struct Liveness {
    pub ping_interval: Duration,
    pub timeout: Duration,
}

When the server revokes the lease of a worker it no longer hears from.

A worker that offers proto::LEASE_LIVENESS sends PING every ping_interval while it holds the lease. The server revokes the lease once it has spent timeout waiting to read from the worker without receiving a byte, or once a write to the worker has made no progress for timeout. Disk work runs on shard threads, never on the reader, and time the reader does not read (a stalled runtime, a shard’s full queue) does not count: the worker’s pings wait in the socket meanwhile.

Fields

ping_interval: Duration

How often the lease holder pings. Default one second.

timeout: Duration

Silence after which the lease is revoked; longer than the interval. Default five seconds.

Trait Implementations

impl Clone for Liveness

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 Liveness

impl Debug for Liveness

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

Formats the value using the given formatter.

impl Default for Liveness

fn default() -> Self

Returns the “default value” for a type.

impl Eq for Liveness

impl PartialEq for Liveness

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Liveness