Struct GenericMetricsCollector 

pub struct GenericMetricsCollector<T>
where
    T: CollectibleMetrics,
{ /* private fields */ }

Generic metrics collector for any operation type

Implementations

impl<T> GenericMetricsCollector<T>

where T: CollectibleMetrics,

pub fn new(collector_name: String) -> Self

Creates a new metrics collector

pub fn with_config( collector_name: String, max_entries: usize, auto_aggregate: bool, ) -> Self

Creates a new metrics collector with custom configuration

pub fn start_operation(&self, operation_id: String) -> Result<(), PipelineError>

Starts tracking an operation

pub fn complete_operation( &self, operation_id: String, operation_type: String, metrics: T, ) -> Result<(), PipelineError>

Completes an operation and records metrics

pub fn record_entry(&self, entry: MetricEntry<T>) -> Result<(), PipelineError>

Records a metric entry directly

pub fn record_failure( &self, operation_id: String, operation_type: String, error: PipelineError, ) -> Result<(), PipelineError>

Records an operation failure

pub fn get_aggregated_metrics(&self) -> Result<T, PipelineError>

Gets the current aggregated metrics

pub fn get_entries(&self) -> Result<Vec<MetricEntry<T>>, PipelineError>

Gets all recorded entries

pub fn get_entries_by_type( &self, operation_type: &str, ) -> Result<Vec<MetricEntry<T>>, PipelineError>

Gets entries filtered by operation type

pub fn get_entries_in_range( &self, start: DateTime<Utc>, end: DateTime<Utc>, ) -> Result<Vec<MetricEntry<T>>, PipelineError>

Gets entries within a time range

pub fn reset(&self) -> Result<(), PipelineError>

Resets all metrics and entries

pub fn get_summary(&self) -> Result<HashMap<String, String>, PipelineError>

Gets summary statistics

pub fn name(&self) -> &str

Gets the collector name

pub fn active_operations_count(&self) -> Result<usize, PipelineError>

Gets the number of active operations