Struct FlowControlSnapshot 

pub struct FlowControlSnapshot {
    pub queues: QueueDepthBytes,
    pub rates: RateWindowBps,
    pub latency: LatencyWindowMs,
    pub serviced_input_bytes: u64,
    pub serviced_output_bytes: u64,
    pub output_hard_cap_duration_ms: u64,
}

Deterministic snapshot consumed by the policy evaluator.

Fields

queues: QueueDepthBytes

Current queue depths.

rates: RateWindowBps

Sliding-window rates.

latency: LatencyWindowMs

Sliding-window latency summary.

serviced_input_bytes: u64

Bytes serviced from input lane in the fairness window.

serviced_output_bytes: u64

Bytes serviced from output lane in the fairness window.

output_hard_cap_duration_ms: u64

How long output queue has continuously stayed at hard cap.

Implementations

impl FlowControlSnapshot

pub fn fairness_index(self) -> f64

Jain fairness index over serviced input/output bytes in this window.

Trait Implementations

impl Clone for FlowControlSnapshot

fn clone(&self) -> FlowControlSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowControlSnapshot

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

Formats the value using the given formatter.

impl PartialEq for FlowControlSnapshot

fn eq(&self, other: &FlowControlSnapshot) -> 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 Copy for FlowControlSnapshot

impl StructuralPartialEq for FlowControlSnapshot