Struct AnalyticsDatabase 

pub struct AnalyticsDatabase { /* private fields */ }

Analytics database manager

Implementations

impl AnalyticsDatabase

pub async fn new(database_path: &Path) -> Result<Self>

Create a new analytics database connection

Arguments

• database_path - Path to the SQLite database file (or “:memory:” for in-memory)

pub async fn run_migrations(&self) -> Result<()>

Run database migrations

pub fn pool(&self) -> &SqlitePool

Get a reference to the database pool

pub async fn insert_minute_aggregate( &self, agg: &MetricsAggregate, ) -> Result<i64>

Insert a minute-level metrics aggregate

pub async fn insert_minute_aggregates_batch( &self, aggregates: &[MetricsAggregate], ) -> Result<()>

Insert multiple minute-level aggregates in a batch

pub async fn insert_hour_aggregate( &self, agg: &HourMetricsAggregate, ) -> Result<i64>

Insert an hour-level metrics aggregate

pub async fn insert_day_aggregate( &self, agg: &DayMetricsAggregate, ) -> Result<i64>

Insert a day-level metrics aggregate

pub async fn upsert_endpoint_stats(&self, stats: &EndpointStats) -> Result<()>

Insert or update endpoint statistics

pub async fn insert_error_event(&self, error: &ErrorEvent) -> Result<i64>

Insert an error event

pub async fn insert_traffic_pattern( &self, pattern: &TrafficPattern, ) -> Result<()>

Insert a traffic pattern

pub async fn insert_snapshot(&self, snapshot: &AnalyticsSnapshot) -> Result<i64>

Insert an analytics snapshot

pub async fn get_minute_aggregates( &self, filter: &AnalyticsFilter, ) -> Result<Vec<MetricsAggregate>>

Get minute aggregates for a time range

pub async fn get_top_endpoints( &self, limit: i64, workspace_id: Option<&str>, ) -> Result<Vec<EndpointStats>>

Get top endpoints by request count

pub async fn get_recent_errors( &self, limit: i64, filter: &AnalyticsFilter, ) -> Result<Vec<ErrorEvent>>

Get recent error events

pub async fn get_traffic_patterns( &self, days: i64, workspace_id: Option<&str>, ) -> Result<Vec<TrafficPattern>>

Get traffic patterns for heatmap

pub async fn cleanup_minute_aggregates(&self, days: u32) -> Result<u64>

Delete old minute aggregates

pub async fn cleanup_hour_aggregates(&self, days: u32) -> Result<u64>

Delete old hour aggregates

pub async fn cleanup_error_events(&self, days: u32) -> Result<u64>

Delete old error events

pub async fn vacuum(&self) -> Result<()>

Vacuum the database to reclaim space

impl AnalyticsDatabase

pub async fn export_to_csv<W: Write>( &self, writer: &mut W, filter: &AnalyticsFilter, ) -> Result<usize>

Export metrics to CSV format

pub async fn export_to_json(&self, filter: &AnalyticsFilter) -> Result<String>

Export metrics to JSON format

pub async fn export_endpoints_to_csv<W: Write>( &self, writer: &mut W, workspace_id: Option<&str>, limit: i64, ) -> Result<usize>

Export endpoint stats to CSV

pub async fn export_errors_to_csv<W: Write>( &self, writer: &mut W, filter: &AnalyticsFilter, limit: i64, ) -> Result<usize>

Export error events to CSV

impl AnalyticsDatabase

pub async fn get_overview_metrics( &self, duration_seconds: i64, ) -> Result<OverviewMetrics>

Get overview metrics for the dashboard

pub async fn get_top_protocols( &self, limit: i64, workspace_id: Option<&str>, ) -> Result<Vec<ProtocolStat>>

Get top protocols by request count

pub async fn get_request_time_series( &self, filter: &AnalyticsFilter, granularity: Granularity, ) -> Result<Vec<TimeSeries>>

Get request count time series

pub async fn get_latency_trends( &self, filter: &AnalyticsFilter, ) -> Result<Vec<LatencyTrend>>

Get latency trends

pub async fn get_error_summary( &self, filter: &AnalyticsFilter, limit: i64, ) -> Result<Vec<ErrorSummary>>

Get error summary

Trait Implementations

impl Clone for AnalyticsDatabase

fn clone(&self) -> AnalyticsDatabase

Returns a duplicate of the value.

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

Performs copy-assignment from source.