Struct Database 

pub struct Database { /* private fields */ }

Database client with connection pooling

Implementations

impl Database

pub async fn new(config: DatabaseConfig) -> Result<Self>

Create a new database client with connection pool

pub async fn from_url(url: &str) -> Result<Self>

Create a new database client from a connection URL

pub fn pool(&self) -> &PgPool

Get a reference to the connection pool

pub async fn close(&self)

Close the database connection pool

pub async fn insert_event(&self, event: &AnalyticsEvent) -> Result<Uuid>

Insert a single analytics event

pub async fn insert_events_batch( &self, events: &[AnalyticsEvent], ) -> Result<u64>

Batch insert analytics events for high throughput

pub async fn query_events( &self, start: DateTime<Utc>, end: DateTime<Utc>, limit: Option<i64>, ) -> Result<Vec<AnalyticsEvent>>

Query events by time range

pub async fn query_events_by_correlation( &self, correlation_id: Uuid, ) -> Result<Vec<AnalyticsEvent>>

Query events by correlation ID

pub async fn store_aggregated_metric( &self, metric_name: &str, time_window: TimeWindow, window_start: DateTime<Utc>, tags: &Value, measures: &StatisticalMeasures, ) -> Result<()>

Store aggregated metrics

pub async fn query_aggregated_metrics( &self, metric_name: &str, time_window: TimeWindow, start: DateTime<Utc>, end: DateTime<Utc>, ) -> Result<Vec<AggregatedMetricRow>>

Query aggregated metrics

pub async fn store_anomaly( &self, anomaly_id: Uuid, detected_at: DateTime<Utc>, metric_name: &str, anomaly_type: &str, severity: &str, value: f64, expected_value: Option<f64>, confidence_score: f64, context: &Value, ) -> Result<Uuid>

Store detected anomaly

pub async fn query_recent_anomalies( &self, since: DateTime<Utc>, limit: Option<i64>, ) -> Result<Vec<AnomalyRow>>

Query recent anomalies

pub async fn store_correlation( &self, correlation_id: Uuid, correlation_type: &str, source_event_id: Uuid, target_event_id: Uuid, strength: f64, metadata: &Value, ) -> Result<Uuid>

Store event correlation

pub async fn health_check(&self) -> Result<DatabaseHealth>

Check database health