Struct PressureMonitor 

pub struct PressureMonitor { /* private fields */ }

Tracks pressure metrics and derives channel pressure scores.

Implementations

impl PressureMonitor

pub fn new() -> Self

Creates an empty pressure monitor with the default average-utilization scorer.

pub fn with_scoring<F>(scoring: F) -> Self

where F: Fn(&[ConsumerPressureMetrics]) -> f64 + Send + Sync + 'static,

Creates an empty pressure monitor using a caller-supplied scoring function.

pub fn is_empty(&self) -> bool

Returns true when no consumers are tracked on any channel.

pub fn total_consumer_count(&self) -> usize

Returns the number of consumers tracked across all channels.

pub fn record_consumer_metrics( &mut self, channel_id: impl Into<String>, consumer_id: impl Into<String>, metrics: ConsumerPressureMetrics, ) -> ChannelPressureSnapshot

Records the latest metrics for a consumer and returns the updated channel snapshot.

pub fn record_accept( &mut self, channel_id: impl Into<String>, consumer_id: impl Into<String>, ) -> ChannelPressureSnapshot

Records one accept decision for a consumer and returns the updated channel snapshot.

pub fn record_defer( &mut self, channel_id: impl Into<String>, consumer_id: impl Into<String>, ) -> ChannelPressureSnapshot

Records one defer decision for a consumer and returns the updated channel snapshot.

pub fn record_reject( &mut self, channel_id: impl Into<String>, consumer_id: impl Into<String>, ) -> ChannelPressureSnapshot

Records one reject decision for a consumer and returns the updated channel snapshot.

pub fn consumer_metrics( &self, channel_id: &str, consumer_id: &str, ) -> Option<&ConsumerPressureMetrics>

Returns the latest metrics recorded for one consumer.

pub fn consumer_utilization( &self, channel_id: &str, consumer_id: &str, ) -> Option<f64>

Returns the latest utilization for one consumer.

pub fn channel_pressure(&self, channel_id: &str) -> f64

Returns the current aggregate pressure score for a channel.

pub fn channel_consumer_count(&self, channel_id: &str) -> usize

Returns the current number of tracked consumers for a channel.

pub fn channel_snapshot(&self, channel_id: &str) -> ChannelPressureSnapshot

Returns an observable snapshot for one channel.

Trait Implementations

impl Debug for PressureMonitor

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

Formats the value using the given formatter.

impl Default for PressureMonitor

fn default() -> Self

Returns the “default value” for a type.