Struct StreamInstrumentationSnapshot 

pub struct StreamInstrumentationSnapshot {
    pub id: StreamInstrumentationId,
    pub name: String,
    pub elements_through: u64,
    pub restarts: u64,
    pub state: StreamInstrumentationState,
    pub started_at: SystemTime,
    pub state_changed_at: SystemTime,
    pub finished_at: Option<SystemTime>,
    pub uptime: Duration,
}

Point-in-time values for one instrumented stream materialization.

Fields

id: StreamInstrumentationId

Stable id assigned when the stream materialized.

name: String

User-provided instrumentation name.

elements_through: u64

Count of successful elements observed by the instrumentation boundary.

restarts: u64

Restart count recorded by the owner of this materialization.

state: StreamInstrumentationState

Current stream state.

started_at: SystemTime

Wall-clock time when this materialization registered.

state_changed_at: SystemTime

Wall-clock time of the most recent state transition.

finished_at: Option<SystemTime>

Wall-clock terminal timestamp when the boundary observed completion or failure.

uptime: Duration

Elapsed time since started_at, or until finished_at for terminal runs.

Trait Implementations

impl Clone for StreamInstrumentationSnapshot

fn clone(&self) -> StreamInstrumentationSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamInstrumentationSnapshot

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

Formats the value using the given formatter.

impl Eq for StreamInstrumentationSnapshot

impl PartialEq for StreamInstrumentationSnapshot

fn eq(&self, other: &StreamInstrumentationSnapshot) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamInstrumentationSnapshot