Struct ChannelPressureSnapshot 

pub struct ChannelPressureSnapshot {
    pub channel_id: String,
    pub pressure_score: f64,
    pub consumers: Vec<ConsumerPressureSnapshot>,
}

Observable pressure snapshot for a channel and all tracked consumers.

Fields

channel_id: String

Channel identifier whose pressure was measured.

pressure_score: f64

Configurable aggregate pressure score clamped to [0.0, 1.0].

consumers: Vec<ConsumerPressureSnapshot>

Per-consumer metric snapshots contributing to the pressure score.

Implementations

impl ChannelPressureSnapshot

pub fn consumer_count(&self) -> usize

Returns the number of consumers currently tracked for the channel.

Trait Implementations

impl Clone for ChannelPressureSnapshot

fn clone(&self) -> ChannelPressureSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelPressureSnapshot

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

Formats the value using the given formatter.

impl PartialEq for ChannelPressureSnapshot

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