Struct AnalyticsStore 

pub struct AnalyticsStore {
    pub workspace_label_mode: WorkspaceLabelMode,
    /* private fields */
}

Fields

workspace_label_mode: WorkspaceLabelMode

Implementations

impl AnalyticsStore

pub fn export_jsonl(&self, output: &mut dyn Write) -> Result<u64>

Streams every turn, tool-call, and token-usage row as normalized JSONL into output. Returns the record count.

impl AnalyticsStore

pub fn tool_summaries(&self, filter: &StatsFilter) -> Result<Vec<ToolSummary>>

Per-tool summaries with exact percentiles computed from raw durations in the filtered window.

pub fn token_summaries( &self, group: TokenGroup, filter: &StatsFilter, ) -> Result<Vec<TokenSummaryRow>>

Token summaries grouped by day, session, provider, model, or workspace. Reads only the projected tables, never raw JSONL.

pub fn session_summaries( &self, filter: &StatsFilter, ) -> Result<Vec<SessionSummary>>

Session summaries sortable by tokens, tool calls, duration, errors.

pub fn usage_summary(&self, filter: &StatsFilter) -> Result<UsageSummary>

Overall window summary for dashboards and stats summary.

pub fn never_used_tools( &self, registered: &[String], filter: &StatsFilter, ) -> Result<Vec<String>>

Registered tools that were never called in the window.

impl AnalyticsStore

pub fn refresh_daily_rollups(&self) -> Result<u64>

Recomputes all daily rollups from raw rows. Deterministic and idempotent: the rollup table always reflects the raw tables.

pub fn daily_rollups(&self) -> Result<Vec<DailyRollupRow>>

impl AnalyticsStore

pub fn open( path: &Path, workspace_label_mode: WorkspaceLabelMode, ) -> Result<Self>

Opens (creating directories and schema as needed) the analytics database at path.

pub fn default_path(data_dir: &Path) -> PathBuf

Default location under a Roder data directory.

pub fn path(&self) -> &Path

pub fn upsert_session(&self, record: &SessionRecord) -> Result<()>

Upserts session metadata. Later non-null values win; created_at_ms keeps the earliest observed value.

pub fn upsert_turn(&self, record: &TurnRecord) -> Result<()>

Upserts a turn keyed by (thread_id, turn_id). Terminal statuses (completed/failed) are never downgraded back to running.

pub fn upsert_token_usage(&self, record: &TokenUsageRecord) -> Result<()>

Upserts terminal token usage for a turn keyed by (thread_id, turn_id); replaying the same terminal event is a no-op rather than a double count.

pub fn upsert_tool_call(&self, record: &ToolCallRecord) -> Result<()>

Upserts a tool call keyed by (thread_id, turn_id, tool_id), merging start/completion halves into one logical record.

pub fn import_offset(&self, source_path: &str) -> Result<Option<u64>>

pub fn record_import_offset( &self, source_path: &str, last_line: u64, source_mtime_ms: Option<i64>, ) -> Result<()>

pub fn clear_all(&self) -> Result<()>

Clears all analytics rows (used by --rebuild before replaying JSONL). The schema and migrations are kept.

pub fn apply_retention(&self, retention_days: u32) -> Result<u64>

Deletes raw rows older than retention_days (sessions are kept while any of their activity remains). Returns the number of deleted rows. 0 days disables pruning. Rollups are not touched here; callers refresh them after pruning.

pub fn counts(&self) -> Result<StoreCounts>