Struct SqliteLogStore 

pub struct SqliteLogStore { /* private fields */ }

SQLite-backed log store with WAL mode for concurrent readers.

Implementations

impl SqliteLogStore

pub fn open(path: impl Into<PathBuf>) -> Result<Self>

Open or create the SQLite log store at the given path.

pub fn rotate_by_age( &self, daemon_id: &DaemonId, max_age: Duration, archive_hook: Option<&ArchiveHook>, ) -> Result<u64>

Rotate (delete) old log entries for a specific daemon based on retention policy.

When an archive hook is configured, entries are fetched in batches of batch_size, the hook is invoked without holding the SQLite mutex (so concurrent log appends are not blocked), and then deleted by ID. Row-read errors are propagated rather than silently dropped.

pub fn rotate_by_count( &self, daemon_id: &DaemonId, max_count: u64, archive_hook: Option<&ArchiveHook>, ) -> Result<u64>

Rotate (delete) old log entries keeping only the most recent max_count rows for a specific daemon.

When an archive hook is configured, entries are fetched in batches of batch_size, the hook is invoked without holding the SQLite mutex (so concurrent log appends are not blocked), and then deleted by ID. Row-read errors are propagated rather than silently dropped.

pub fn migrate_daemon_text_logs(&self, daemon_id: &DaemonId) -> Result<u64>

Migrate existing text logs for a daemon into SQLite.

Reads the legacy text file line-by-line (streaming) and inserts in batches of 1000 to avoid loading multi-GB files into memory at once.

pub fn distinct_loggers(&self, daemon_id: &str) -> Result<Vec<String>>

Return distinct non-null logger values for a daemon, sorted alphabetically.

Scans only the most recent 5000 entries for performance — autocomplete only needs a representative sample, not the full history.

pub fn distinct_field_keys(&self, daemon_id: &str) -> Result<Vec<String>>

Return distinct keys from the fields_json column for a daemon.

Uses json_each to extract all object keys across recent structured log entries, returning a sorted unique list. Useful for jq autocomplete. Scans only the most recent 5000 entries for performance.

Trait Implementations

impl LogStore for SqliteLogStore

fn append(&self, daemon_id: &DaemonId, message: &str) -> Result<()>

Append a single log line (unstructured).

fn append_batch(&self, daemon_id: &DaemonId, messages: &[String]) -> Result<()>

Append multiple log lines in a single transaction.

fn append_structured( &self, daemon_id: &DaemonId, parsed: &ParsedLog, ) -> Result<()>

Append a single parsed log line with structured fields.

fn append_structured_batch( &self, daemon_id: &DaemonId, entries: &[ParsedLog], ) -> Result<()>

Append multiple parsed log lines in a single transaction.

fn query(&self, opts: &LogQuery) -> Result<Vec<LogEntry>>

Query logs according to the given options.

fn tail( &self, daemon_id: &DaemonId, after_id: Option<i64>, ) -> Result<Vec<LogEntry>>

Read new log entries for a daemon. When after_id is Some(id), returns only entries with row id > id. When after_id is None, returns all entries for the daemon.

fn clear(&self, daemon_ids: &[DaemonId]) -> Result<()>

Clear all logs for the given daemon(s).

fn last_id(&self, daemon_id: &DaemonId) -> Result<Option<i64>>

Return the highest row id for the given daemon, or None if no entries exist. Used by tailing loops to advance the cursor past non-matching rows without re-scanning them on every poll.

fn list_daemon_ids(&self) -> Result<Vec<String>>

List all daemon IDs that have log entries.

fn apply_retention( &self, policy: &RetentionPolicy, excluded_daemon_ids: &[DaemonId], archive_hook: Option<&ArchiveHook>, ) -> Result<u64>

Apply a retention policy (age-based and/or count-based pruning).

fn apply_retention_for_daemon( &self, daemon_id: &DaemonId, policy: &RetentionPolicy, archive_hook: Option<&ArchiveHook>, ) -> Result<u64>

Apply a retention policy to a specific daemon’s logs.

fn last_clear_generation(&self, daemon_id: &DaemonId) -> Result<Option<u64>>

Return the generation number for the daemon’s last clear operation. Each call to clear bumps the generation, so SSE streams can detect when logs have been wiped and refresh their display.

fn query_with_generation( &self, opts: &LogQuery, daemon_id: &DaemonId, ) -> Result<(Vec<LogEntry>, Option<u64>)>

Query logs and the current clear generation atomically.