Struct Db 

pub struct Db { /* private fields */ }

Implementations

impl Db

pub fn open() -> Result<Self>

pub fn open_read_only() -> Result<Self>

pub fn open_path(path: impl AsRef<Path>) -> Result<Self>

pub fn open_read_only_path(path: impl AsRef<Path>) -> Result<Self>

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

pub fn record_message(&self, record: MessageRecord<'_>) -> Result<i64>

pub fn record_cli( &self, ts_utc: DateTime<Utc>, bin: &str, argv_json: &str, exit_code: Option<i64>, duration_ms: Option<i64>, host: &str, ) -> Result<i64>

pub fn record_crash( &self, ts_utc: DateTime<Utc>, kind: &str, agent: &str, detail_json: &str, ) -> Result<i64>

pub fn record_tick( &self, ts_utc: DateTime<Utc>, source: &str, detail_json: &str, ) -> Result<i64>

pub fn record_workspace( &self, ts_utc_created: DateTime<Utc>, name: &str, branch: &str, ts_utc_deleted: Option<DateTime<Utc>>, verdict: Option<&str>, ) -> Result<i64>

pub fn record_session( &self, ts_utc: DateTime<Utc>, agent: &str, session_num: i64, event: SessionEvent, ) -> Result<i64>

pub fn record_clone_dispatch( &self, record: CloneDispatchRecord<'_>, ) -> Result<i64>

pub fn record_harvest_event( &self, record: HarvestEventRecord<'_>, ) -> Result<i64>

pub fn record_communication_event( &self, record: CommunicationEventRecord<'_>, ) -> Result<i64>

pub fn list_communication_events(&self) -> Result<Vec<CommunicationEvent>>

pub fn record_mcp_tool_call(&self, record: McpToolCallRecord<'_>) -> Result<i64>

pub fn record_git_operation( &self, record: GitOperationRecord<'_>, ) -> Result<i64>

pub fn record_owner_directive( &self, record: OwnerDirectiveRecord<'_>, ) -> Result<i64>

pub fn record_token_usage(&self, record: TokenUsageRecord<'_>) -> Result<i64>

pub fn record_token_usage_batch<'a, I>(&self, records: I) -> Result<usize>

where I: IntoIterator<Item = TokenUsageRecord<'a>>,

Batch-insert token usage rows. One turso connection, one transaction, one bulk id allocation. Use this from ingest paths that emit thousands of rows; per-row [record_token_usage] opens a fresh turso connection per call which is dominated by setup cost.

Returns the number of rows written. Empty input is a no-op.

pub fn record_source_error(&self, record: SourceErrorRecord<'_>) -> Result<i64>

pub fn record_iroh_event(&self, record: IrohEventRecord<'_>) -> Result<i64>

pub fn record_watchdog_event( &self, record: WatchdogEventRecord<'_>, ) -> Result<i64>

pub fn read_source_cursor(&self, source: &str) -> Result<Option<String>>

Read the cursor recorded for this source. None means no cursor has been written yet (first-run).

pub fn update_source_cursor(&self, source: &str, value: &str) -> Result<()>

Write (upsert) the cursor for this source. updated_at is set to the current UTC instant.

pub fn reset_source_cursor(&self, source: &str) -> Result<bool>

Delete the cursor row for this source. Idempotent; returns whether a row was removed.

pub fn list_source_cursors(&self) -> Result<Vec<SourceCursorRow>>

pub fn insert_event( &self, source: &str, ts_utc: DateTime<Utc>, payload_json: &str, ) -> Result<i64>

Insert an event row with delivery_status = 'pending'. Returns the allocated id so the caller can update the status after the delivery adapter runs.

pub fn update_event_delivery( &self, id: i64, status: EventStatus, reason: Option<&str>, ) -> Result<()>

Transition an event to delivered or failed. reason is the failure text for failed; ignored (but recorded) for delivered.

pub fn tail_events(&self, source: &str, limit: i64) -> Result<Vec<EventRow>>

Tail the most recent events for a source (newest first).

pub fn record_task(&self, record: TaskRecord<'_>) -> Result<i64>

pub fn update_task(&self, update: TaskUpdate<'_>) -> Result<TaskRow>

pub fn get_task(&self, id: i64) -> Result<Option<TaskRow>>

pub fn list_tasks( &self, status: Option<&str>, priority: Option<&str>, ) -> Result<Vec<TaskRow>>

pub fn query(&self, sql: &str) -> Result<String>

pub fn query_batches(&self, sql: &str) -> Result<Vec<RecordBatch>>

pub fn schema_version(&self) -> Result<i64>