Struct MetricsRepository 

pub struct MetricsRepository { /* private fields */ }

Implementations

impl MetricsRepository

pub fn new(pool: SqlitePool) -> Self

pub fn new_from_pool(pool: DatabasePool) -> Self

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

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 upsert_pipeline_config( &self, pipeline_id: &str, enabled: bool, retention_days: i64, ) -> DomainResult<()>

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

pub async fn update_last_processed_run( &self, pipeline_id: &str, run_number: i64, ) -> DomainResult<()>

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

pub async fn reset_all_processing_states(&self) -> DomainResult<()>

pub async fn insert_metrics_batch( &self, metrics: Vec<MetricEntry>, ) -> 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 delete_old_metrics( &self, pipeline_id: Option<&str>, ) -> DomainResult<usize>

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

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

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

pub async fn export_config(&self) -> DomainResult<MetricsConfigExport>

pub async fn import_config( &self, export: &MetricsConfigExport, ) -> DomainResult<()>

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

pub async fn reset_all_corrupted_states(&self) -> DomainResult<Vec<String>>