Struct SqliteTelemetryStore 

pub struct SqliteTelemetryStore { /* private fields */ }

A TelemetryStore backed by an embedded SQLite database.

All data (metrics, events, snapshots) is persisted to a single SQLite file and can be queried by timestamp range. A configurable RetentionPolicy controls automatic purging of old data.

Implementations

impl SqliteTelemetryStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, TelemetryError>

Open (or create) a SQLite telemetry store at the given path.

pub fn open_with_retention( path: impl AsRef<Path>, retention: RetentionPolicy, ) -> Result<Self, TelemetryError>

Open with a custom retention policy.

pub fn in_memory() -> Result<Self, TelemetryError>

Create an in-memory SQLite store (useful for testing).

pub const fn set_retention(&mut self, retention: RetentionPolicy)

Set the retention policy.

pub fn apply_retention(&mut self) -> Result<RetentionStats, TelemetryError>

Apply the retention policy, deleting records older than the configured thresholds.

pub fn stats(&self) -> Result<StoreStats, TelemetryError>

Return database statistics.

Trait Implementations

impl TelemetryStore for SqliteTelemetryStore

fn write_metric(&mut self, sample: MetricSample) -> Result<(), TelemetryError>

fn latest_metrics(&self) -> Result<Vec<MetricSample>, TelemetryError>

fn metrics_between( &self, from: &str, to: &str, ) -> Result<Vec<MetricSample>, TelemetryError>

fn write_event(&mut self, event: DockerEvent) -> Result<(), TelemetryError>

fn events_between( &self, from: &str, to: &str, ) -> Result<Vec<DockerEvent>, TelemetryError>

fn write_snapshot( &mut self, snapshot: TelemetrySnapshot, ) -> Result<(), TelemetryError>

fn snapshot_at_or_before( &self, timestamp: &str, ) -> Result<Option<TelemetrySnapshot>, TelemetryError>

fn all_snapshots(&self) -> Result<Vec<TelemetrySnapshot>, TelemetryError>

fn write_alert_event( &mut self, event: AlertHistoryEvent, ) -> Result<(), TelemetryError>

fn alert_history( &self, from: &str, to: &str, ) -> Result<Vec<AlertHistoryEvent>, TelemetryError>