Struct CollapseDetector 

pub struct CollapseDetector { /* private fields */ }

Per-connection collapse detector.

Implementations

impl CollapseDetector

pub fn new() -> Self

pub fn observe_rate(&mut self, rate: f64)

Record an observed instantaneous rate (bytes/s) for this connection.

pub fn observe_silence(&mut self, since_progress_s: f64, stall_timeout_s: f64)

Escalate on wall-clock silence, which no rate sample can express: a connection delivering nothing produces no observations at all.

pub fn mark_dead(&mut self)

pub fn health(&self) -> Health

pub fn rate(&self) -> f64

Established rate, for scheduling decisions that need a number.

pub fn samples(&self) -> u32

pub fn reset_after_repair(&mut self)

Clear detection state after work has been moved away, so the next episode is judged on fresh evidence.

Trait Implementations

impl Clone for CollapseDetector

fn clone(&self) -> CollapseDetector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CollapseDetector

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

Formats the value using the given formatter.

impl Default for CollapseDetector

fn default() -> Self

Returns the “default value” for a type.