Struct SqliteAdminAuditWriter 

pub struct SqliteAdminAuditWriter { /* private fields */ }

SQLite-backed AdminAuditWriter. Production daemons construct one at boot and feed it to AdminRpcDispatcher::with_audit_writer.

Implementations

impl SqliteAdminAuditWriter

pub async fn open(path: &Path) -> Result<Self>

Open or create the audit DB at path. Idempotent — the inline DDL runs on every boot. Pool kept small (2 conns) since audit writes are infrequent and append-only.

pub async fn open_memory() -> Result<Self>

In-memory variant for tests. No filesystem path; pool drops content on Self::Drop.

pub async fn sweep_retention( &self, retention_days: u64, max_rows: usize, ) -> Result<usize>

Boot-time retention sweep. Deletes rows older than retention_days AND drops the oldest beyond max_rows. Returns total rows deleted. Errors propagate — caller (boot supervisor) logs them; admin dispatch never depends on this fn.

pub async fn tail(&self, filter: &AuditTailFilter) -> Result<AuditTailPage>

Tail recent audit rows with filter + pagination support. Returns an AuditTailPage with entries, total, has_more, and next_offset so callers (CLI tail formatter + the nexo/admin/microapp_audit/tail admin RPC) can render “showing N of M” UI labels and offer “load more” controls.

Filter combinator → SQL: every Some-field appends an AND clause. Result is ordered newest-first by started_at_ms. limit = 0 defaults to 50; clamped to [1, 500].

pub async fn tail_for_tenant( &self, tenant_id: &str, since_ms: Option<u64>, limit: usize, ) -> Result<Vec<AdminAuditRow>>

Convenience tail bound to a single tenant. Equivalent to tail() with tenant_id = Some(tenant), since_ms, and limit set; other filters left empty. Used by the nexo/admin/audit/tail_for_tenant CLI/RPC subcommand and by SaaS billing pipelines.

Trait Implementations

impl AdminAuditReader for SqliteAdminAuditWriter

fn tail<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 AuditTailFilter, ) -> Pin<Box<dyn Future<Output = Result<AuditTailPage>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return one paginated page of audit rows matching filter. Newest-first order.

impl AdminAuditWriter for SqliteAdminAuditWriter

fn append<'life0, 'async_trait>( &'life0 self, row: AdminAuditRow, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append one row. Errors are logged but not propagated — audit failures must never block admin dispatch.

impl Clone for SqliteAdminAuditWriter

fn clone(&self) -> SqliteAdminAuditWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteAdminAuditWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.