Enum BackpressureSignal 

pub enum BackpressureSignal {
    None,
    Mild {
        factor: f64,
    },
    Severe {
        factor: f64,
    },
    Overloaded,
}

Global backpressure signal reported by the application or transport layer.

Variants

None

No backpressure — operate at full rate.

Mild

Mild congestion — reduce rates by the given factor (0, 1].

Fields

factor: f64

Multiplicative factor applied to base_requests_per_peer.

Severe

Severe congestion — heavily reduce rates.

Fields

factor: f64

Multiplicative factor applied to base_requests_per_peer.

Overloaded

System is overloaded — allocate zero requests to every peer.

Implementations

impl BackpressureSignal

pub fn factor(&self) -> f64

Returns the multiplicative factor for this signal.

• None → 1.0
• Mild → the stored factor
• Severe → the stored factor
• Overloaded→ 0.0

pub fn label(&self) -> &'static str

Human-readable label used in SchedulerStats.

Trait Implementations

impl Clone for BackpressureSignal

fn clone(&self) -> BackpressureSignal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureSignal

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

Formats the value using the given formatter.

impl PartialEq for BackpressureSignal

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BackpressureSignal