Struct SqliteToolExecutionStore 

pub struct SqliteToolExecutionStore { /* private fields */ }

SQLite-backed rebuildable tool-execution projection store.

Implementations

impl SqliteToolExecutionStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, AgentError>

Opens or creates a SQLite tool-execution projection store.

Trait Implementations

impl Clone for SqliteToolExecutionStore

fn clone(&self) -> SqliteToolExecutionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteToolExecutionStore

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

Formats the value using the given formatter.

impl ToolExecutionStore for SqliteToolExecutionStore

fn put_tool_execution_record( &self, record: ToolExecutionStoreRecord, ) -> Result<ToolExecutionStoreCursor, AgentError>

Stores one redacted tool-execution projection row.

fn records_for_run( &self, run_id: &RunId, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads all projection rows for one run, ordered by journal sequence.

fn record_for_tool_call( &self, run_id: &RunId, tool_call_id: &ToolCallId, ) -> Result<Option<ToolExecutionStoreRecord>, AgentError>

Reads one projection row for a tool call.

fn records_for_idempotency_key( &self, idempotency_key: &IdempotencyKey, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads projection rows with the supplied idempotency key.

fn records_for_effect_id( &self, effect_id: &EffectId, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads projection rows with the supplied effect id.

fn records_after_journal_seq( &self, run_id: &RunId, journal_seq: u64, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads projection rows for one run after a durable journal sequence.

fn records_in_journal_cursor_range( &self, run_id: &RunId, after: Option<&JournalCursor>, through: Option<&JournalCursor>, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads projection rows for one run inside a durable journal cursor range.