Struct ParticipantPumpDiagnostics 

pub struct ParticipantPumpDiagnostics {
    pub pumps_run: u64,
    pub reads_timed_out: u64,
}

What a participant handle’s quiet drains have done on its current connection, read without a lock and without touching the socket.

try_receive ends a quiet drain on a transport fence, never on elapsed silence, so on a healthy connection reads_timed_out stays at zero however many pumps run. A read window that closes before the fence’s reply arrives is counted there. Both counts start at zero when a connection is established and are not carried across a reconnect.

Fields

pumps_run: u64

Quiet drains run: each call to try_receive that reached the transport.

reads_timed_out: u64

Socket reads inside those drains that ended because their read window closed with nothing to read.

Trait Implementations

impl Clone for ParticipantPumpDiagnostics

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 ParticipantPumpDiagnostics

impl Debug for ParticipantPumpDiagnostics

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

Formats the value using the given formatter.

impl Default for ParticipantPumpDiagnostics

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ParticipantPumpDiagnostics

impl PartialEq for ParticipantPumpDiagnostics

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ParticipantPumpDiagnostics