Struct StreamInspectorSnapshot 

pub struct StreamInspectorSnapshot {
    pub stream_id: Symbol,
    pub route: Symbol,
    pub media: StreamMedia,
    pub profile: Symbol,
    pub clock: Symbol,
    pub status: StreamInspectorStatus,
    pub buffer: BufferPolicy,
    pub queue_depth: usize,
    pub dropped_count: u64,
    pub last_sequence: Option<u64>,
    pub recent_diagnostics: Vec<Symbol>,
}

Point-in-time observation of a single stream’s identity and health.

Captures the stream’s metadata-derived identity (id, media, clock, buffer policy), its routing and transport profile, its current StreamInspectorStatus, and live queue/loss counters. Render with StreamInspectorSnapshot::to_expr to hand the snapshot to a codec.

Fields

stream_id: Symbol

Stable identifier of the observed stream.

route: Symbol

Route the stream is being observed on.

media: StreamMedia

Media kind carried by the stream.

profile: Symbol

Name of the transport profile in effect.

clock: Symbol

Clock domain the stream is timed against.

status: StreamInspectorStatus

Current lifecycle status of the stream.

buffer: BufferPolicy

Bounded buffer policy governing the stream’s queue.

queue_depth: usize

Number of items currently queued in the buffer.

dropped_count: u64

Total items dropped (newest plus oldest) since the stream opened.

last_sequence: Option<u64>

Sequence number of the most recent observed item, if any.

recent_diagnostics: Vec<Symbol>

Recent diagnostic symbols collected for the stream.

Implementations

impl StreamInspectorSnapshot

pub fn new( metadata: &StreamMetadata, route: Symbol, profile: Symbol, status: StreamInspectorStatus, queue_depth: usize, stats: &StreamStats, last_sequence: Option<u64>, recent_diagnostics: Vec<Symbol>, ) -> Self

Builds a snapshot from stream metadata, stats, and observed counters.

pub fn from_stream_value( stream: &StreamValue, route: Symbol, profile: &TransportProfile, recent_diagnostics: Vec<Symbol>, ) -> Result<Self>

Builds a snapshot by querying a live StreamValue.

Reads the stream’s stats, queue depth, and completion flag to derive the last observed sequence and StreamInspectorStatus. Returns an error if any of those queries fail.

pub fn to_expr(&self) -> Expr

Renders the snapshot as a tagged Expr map for codec round-tripping.

Trait Implementations

impl Clone for StreamInspectorSnapshot

fn clone(&self) -> StreamInspectorSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamInspectorSnapshot

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

Formats the value using the given formatter.

impl Eq for StreamInspectorSnapshot

impl PartialEq for StreamInspectorSnapshot

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