Struct PostgresToolExecutionStore 

pub struct PostgresToolExecutionStore { /* private fields */ }

Implementations

impl PostgresToolExecutionStore

pub fn new(client: PostgresStoreClient) -> Self

Trait Implementations

impl Clone for PostgresToolExecutionStore

fn clone(&self) -> PostgresToolExecutionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ToolExecutionStore for PostgresToolExecutionStore

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 records_for_effect_id( &self, effect_id: &EffectId, ) -> Result<Vec<ToolExecutionStoreRecord>, AgentError>

Reads projection rows with the supplied effect id.

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_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.