Struct MetricsService 

pub struct MetricsService { /* private fields */ }

Implementations

impl MetricsService

pub fn new(repository: Arc<MetricsRepository>) -> Self

pub fn repository(&self) -> Arc<MetricsRepository>

pub async fn get_global_config(&self) -> DomainResult<GlobalMetricsConfig>

pub async fn update_global_config( &self, enabled: bool, default_retention_days: i64, ) -> DomainResult<()>

pub async fn get_pipeline_config( &self, pipeline_id: &str, ) -> DomainResult<Option<MetricsConfig>>

pub async fn get_effective_pipeline_config( &self, pipeline_id: &str, ) -> DomainResult<MetricsConfig>

pub async fn update_pipeline_config( &self, pipeline_id: &str, enabled: bool, retention_days: i64, ) -> DomainResult<()>

pub async fn extract_and_store_metrics( &self, pipeline_id: &str, runs: &[PipelineRun], ) -> DomainResult<usize>

pub async fn query_metrics( &self, query: MetricsQuery, ) -> DomainResult<Vec<MetricEntry>>

pub async fn query_aggregated_metrics( &self, query: MetricsQuery, ) -> DomainResult<AggregatedMetrics>

pub async fn cleanup_old_metrics(&self) -> DomainResult<usize>

pub async fn get_storage_stats(&self) -> DomainResult<MetricsStats>

pub async fn flush_metrics( &self, pipeline_id: Option<&str>, skip_vacuum: bool, ) -> DomainResult<usize>

pub async fn reset_pipeline_processing( &self, pipeline_id: &str, ) -> DomainResult<()>