Struct ShadowEventStore 

pub struct ShadowEventStore { /* private fields */ }

Persistent storage for the safety shadow event stream.

Thin wrapper around DbPool for the safety_shadow_events table. Methods are async and return typed errors.

Implementations

impl ShadowEventStore

pub fn new(pool: DbPool) -> Self

Create a ShadowEventStore backed by the given pool.

pub async fn record(&self, event: &ShadowEvent) -> Result<(), AgentError>

Persist a shadow event to the database.

The id field of the event is ignored; the database assigns a new row id.

Errors

Returns AgentError on database failure.

pub async fn get_trajectory( &self, session_id: &str, limit: usize, ) -> Result<Vec<ShadowEvent>, AgentError>

Retrieve the last limit events for a session in ascending time order.

Used to build the trajectory context for probe evaluation.

Errors

Returns AgentError on database failure.

pub async fn get_tool_history( &self, tool_id: &str, limit: usize, ) -> Result<Vec<ShadowEvent>, AgentError>

Retrieve the last limit events for a specific tool across all sessions.

Used for cross-session pattern detection.

Errors

Returns AgentError on database failure.

Trait Implementations

impl Clone for ShadowEventStore

fn clone(&self) -> ShadowEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.