Enum StreamInspectorStatus 

pub enum StreamInspectorStatus {
    Live,
    Ended,
    Cancelled,
    BufferOverflow,
    Disconnected,
    Reconnecting,
    RefusedProfile,
    Faulted,
}

Lifecycle classification of an observed stream.

Reported by StreamInspectorSnapshot to describe whether a stream is still flowing, has finished, or has entered a degraded or terminal condition. Each variant carries a stable wire label and qualified symbol.

Variants

Live

Stream is open and actively delivering items.

Ended

Stream closed normally after delivering its items.

Cancelled

Stream was cancelled by a consumer or producer.

BufferOverflow

Stream’s bounded buffer dropped, rejected, or overflowed items.

Disconnected

Stream transport is currently disconnected.

Reconnecting

Stream transport is attempting to re-establish a connection.

RefusedProfile

Stream’s transport profile was refused as unsupported.

Faulted

Stream has been forced into a fault condition for inspection.

Implementations

impl StreamInspectorStatus

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

Returns the stable lowercase wire label for this status.

pub fn symbol(self) -> Symbol

Returns this status as a stream/inspector-status/<label> symbol.

pub fn from_stats(stats: &StreamStats, done: bool) -> Self

Classifies a stream’s status from its runtime stats.

Precedence is cancellation, then buffer loss (any dropped, overflowed, or rejected items), then end-of-stream (done or closed), otherwise StreamInspectorStatus::Live.

Trait Implementations

impl Clone for StreamInspectorStatus

fn clone(&self) -> StreamInspectorStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamInspectorStatus

impl Debug for StreamInspectorStatus

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

Formats the value using the given formatter.

impl Eq for StreamInspectorStatus

impl PartialEq for StreamInspectorStatus

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