Struct StageMetrics 

pub struct StageMetrics {
    pub processing_time: Option<Duration>,
    pub success_count: usize,
    pub failure_count: usize,
    pub additional_info: HashMap<String, String>,
}

Metrics collected during stage processing.

This provides consistent performance and error tracking across all pipeline stages.

Fields

processing_time: Option<Duration>

Time taken to process the stage

success_count: usize

Number of items successfully processed

failure_count: usize

Number of items that failed processing

additional_info: HashMap<String, String>

Additional stage-specific metrics

Implementations

impl StageMetrics

pub fn new(success_count: usize, failure_count: usize) -> Self

Create new metrics with the given counts

pub fn with_processing_time(self, duration: Duration) -> Self

Set the processing time

pub fn with_info<K: Into<String>, V: Into<String>>( self, key: K, value: V, ) -> Self

Add additional information to the metrics

pub fn total_count(&self) -> usize

Get the total number of items processed

pub fn success_rate(&self) -> f64

Get the success rate as a percentage

Trait Implementations

impl Clone for StageMetrics

fn clone(&self) -> StageMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StageMetrics

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

Formats the value using the given formatter.

impl Default for StageMetrics

fn default() -> StageMetrics

Returns the “default value” for a type.