Struct StreamingStats 

pub struct StreamingStats {
    pub chunks_processed: usize,
    pub chunks_dropped: usize,
    pub backpressure_events: usize,
    pub late_events_dropped: usize,
    pub total_processing_time_ms: u64,
    pub total_elements_processed: usize,
}

Runtime statistics for a stream processing session.

Fields

chunks_processed: usize

Number of chunks that were successfully processed.

chunks_dropped: usize

Number of chunks that were dropped (e.g. due to backpressure or late arrival).

backpressure_events: usize

Number of times backpressure was triggered.

late_events_dropped: usize

Number of events dropped because they were late (beyond the watermark).

total_processing_time_ms: u64

Total wall-clock processing time in milliseconds.

total_elements_processed: usize

Total number of individual data elements processed across all chunks.

Implementations

impl StreamingStats

pub fn average_latency_ms(&self) -> f64

Average latency per processed chunk in milliseconds. Returns 0.0 when no chunks have been processed.

pub fn drop_rate(&self) -> f64

Fraction of chunks that were dropped: dropped / (processed + dropped). Returns 0.0 when no chunks have been seen at all.

pub fn throughput_chunks_per_sec(&self) -> f64

Throughput in chunks per second. Returns 0.0 when no processing time has been recorded.

pub fn merge(&mut self, other: &StreamingStats)

Merge another StreamingStats into this one by summing all fields.

Trait Implementations

impl Clone for StreamingStats

fn clone(&self) -> StreamingStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingStats

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

Formats the value using the given formatter.

impl Default for StreamingStats

fn default() -> StreamingStats

Returns the “default value” for a type.