Struct BackpressureEntry 

pub struct BackpressureEntry {
    pub notices_sent: u32,
    pub last_notice_at_ns: u64,
    pub last_min_backoff_ns: u64,
    pub silent_drop_active: bool,
}

Per-peer back-pressure bookkeeping.

Fields

notices_sent: u32

Total notices emitted to this peer since the last reset. Reset to 0 when the peer’s φ collapses back below Suspect.

last_notice_at_ns: u64

now_ns recorded at the most recent notice emission. 0 if none have been emitted yet. Used together with last_min_backoff_ns to suppress redundant notices inside the previously-quoted back-off window.

last_min_backoff_ns: u64

min_backoff_ns quoted on the most recent notice. The duplicate-suppression check skips emission while now_ns < last_notice_at_ns + last_min_backoff_ns. 0 when no notice has been emitted yet.

silent_drop_active: bool

true once notices_sent >= K without observed recovery. Phase 1 of Engine::poll drops envelopes from this peer while set.

Trait Implementations

impl Clone for BackpressureEntry

fn clone(&self) -> BackpressureEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BackpressureEntry

impl Debug for BackpressureEntry

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

Formats the value using the given formatter.

impl Default for BackpressureEntry

fn default() -> BackpressureEntry

Returns the “default value” for a type.