Struct TelemetryStorage 

pub struct TelemetryStorage { /* private fields */ }

Telemetry storage backend using SQLite

Implementations

impl TelemetryStorage

pub async fn new(db_path: &Path) -> TelemetryResult<Self>

Create a new storage backend

pub async fn initialize_default() -> TelemetryResult<Self>

Initialize with default configuration

Uses ~/.local/share/reasonkit/.rk_telemetry.db on Linux/Mac or the appropriate XDG data directory.

pub fn in_memory() -> TelemetryResult<Self>

Create an in-memory storage (for testing)

pub fn schema_version(&self) -> TelemetryResult<u32>

Get current schema version

pub fn db_path(&self) -> &str

Get database file path

pub fn noop() -> Self

Create a no-op storage (when telemetry is disabled)

pub async fn insert_session(&mut self, session_id: Uuid) -> TelemetryResult<()>

Insert a session record (required before inserting traces/queries)

pub async fn insert_query_event( &mut self, event: &QueryEvent, ) -> TelemetryResult<()>

Insert a query event

pub async fn insert_feedback_event( &mut self, event: &FeedbackEvent, ) -> TelemetryResult<()>

Insert a feedback event

pub async fn insert_trace_event( &mut self, event: &TraceEvent, ) -> TelemetryResult<()>

Insert a trace event

pub async fn get_aggregated_metrics(&self) -> TelemetryResult<AggregatedMetrics>

Get aggregated metrics

pub async fn export_anonymized(&self) -> TelemetryResult<CommunityExport>

Export anonymized data for community contribution

pub async fn run_daily_aggregation(&mut self, date: &str) -> TelemetryResult<()>

Run daily aggregation

pub async fn get_db_size(&self) -> TelemetryResult<u64>

Get database size in bytes

pub async fn prune_old_data( &mut self, retention_days: u32, ) -> TelemetryResult<u64>

Prune old data based on retention policy

pub async fn vacuum(&mut self) -> TelemetryResult<()>

Vacuum database to reclaim space

pub async fn get_query_count(&self) -> TelemetryResult<u64>

Get query count