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: &SentinelEvent) -> 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<SentinelEvent>, 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, exclude_session_id: &str, limit: usize, ) -> Result<Vec<SentinelEvent>, AgentError>

Retrieve the last limit events for a specific tool from sessions OTHER than exclude_session_id.

Used for cross-session pattern detection. The exclusion is applied in SQL (not just filtered client-side afterward) so that a session with heavy recent activity for tool_id cannot crowd its own rows into the LIMIT clip and starve genuinely cross-session rows out of the result.

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.