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, ) -> Result<u64>

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

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

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

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.

Trait Implementations

impl LogStore for SqliteLogStore

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

Append a single log line.

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 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], ) -> Result<u64>

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

fn apply_retention_for_daemon( &self, daemon_id: &DaemonId, policy: &RetentionPolicy, ) -> 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.