Struct StreamMetrics

pub struct StreamMetrics {
    pub items_processed: u64,
    pub bytes_processed: u64,
    pub processing_time: Duration,
    pub errors: u64,
    pub start_time: Option<Instant>,
}

Metrics collected for rs2_stream operations

Fields

items_processed: u64

bytes_processed: u64

processing_time: Duration

errors: u64

start_time: Option<Instant>

Implementations

impl StreamMetrics

pub fn new() -> Self

pub fn record_item(&mut self, size_bytes: u64)

pub fn record_error(&mut self)

pub fn finalize(&mut self)

pub fn throughput_items_per_sec(&self) -> f64

pub fn throughput_bytes_per_sec(&self) -> f64

Trait Implementations

impl Clone for StreamMetrics

fn clone(&self) -> StreamMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMetrics

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

Formats the value using the given formatter.

impl Default for StreamMetrics

fn default() -> StreamMetrics

Returns the “default value” for a type.