Struct StreamingQualityMetrics 

pub struct StreamingQualityMetrics {
    pub total_deltas: usize,
    pub avg_delta_size: usize,
    pub min_delta_size: usize,
    pub max_delta_size: usize,
    pub pattern: StreamingPattern,
    pub snapshot_repairs_count: usize,
    pub large_delta_count: usize,
    pub protocol_violations: usize,
    pub queue_depth: usize,
    pub queue_dropped_events: usize,
    pub queue_backpressure_count: usize,
}

Streaming quality metrics for analyzing streaming behavior.

These metrics help diagnose issues with streaming performance and inform future improvements to the streaming infrastructure.

Metrics Tracked

• Delta sizes: Average, min, max sizes to understand streaming granularity
• Total deltas: Count of deltas processed
• Streaming pattern: Classification based on size variance
• Queue metrics: Event queue depth, dropped events, and backpressure (when using bounded queue)

Fields

total_deltas: usize

Total number of deltas processed

avg_delta_size: usize

Average delta size in bytes

min_delta_size: usize

Minimum delta size in bytes

max_delta_size: usize

Maximum delta size in bytes

pattern: StreamingPattern

Classification of streaming pattern

snapshot_repairs_count: usize

Number of times auto-repair was triggered for snapshot-as-delta bugs

large_delta_count: usize

Number of deltas that exceeded the size threshold (indicating potential snapshots)

protocol_violations: usize

Number of protocol violations detected (e.g., MessageStart during streaming)

queue_depth: usize

Queue depth (number of events in queue) - 0 if queue not in use

queue_dropped_events: usize

Number of events dropped due to queue overflow - 0 if queue not in use

queue_backpressure_count: usize

Number of times backpressure was triggered (send blocked on full queue) - 0 if queue not in use

Implementations

impl StreamingQualityMetrics

pub fn from_sizes<I: Iterator<Item = usize>>(sizes: I) -> Self

Create metrics from a collection of delta sizes.

Arguments

• sizes - Iterator of delta sizes in bytes

pub fn format(&self, colors: Colors) -> String

Format metrics for display.

Trait Implementations

impl Clone for StreamingQualityMetrics

fn clone(&self) -> StreamingQualityMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingQualityMetrics

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

Formats the value using the given formatter.

impl Default for StreamingQualityMetrics

fn default() -> StreamingQualityMetrics

Returns the “default value” for a type.