Struct NodeBackpressure 

pub struct NodeBackpressure {
    pub node_id: String,
    pub level: BackpressureLevel,
    pub fill_ratio: f64,
    pub timestamp_ms: u64,
}

Backpressure signal from a single node.

Fields

node_id: String

Node identifier.

level: BackpressureLevel

Current backpressure level.

fill_ratio: f64

Queue fill ratio that led to this level (0.0–1.0).

timestamp_ms: u64

Timestamp when this signal was recorded (Unix epoch ms).

Implementations

impl NodeBackpressure

pub fn from_fill( node_id: impl Into<String>, fill_ratio: f64, timestamp_ms: u64, ) -> Self

Create a node backpressure signal from a fill ratio.

Trait Implementations

impl Clone for NodeBackpressure

fn clone(&self) -> NodeBackpressure

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeBackpressure

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

Formats the value using the given formatter.