Struct Store 

pub struct Store {
    pub conn: Arc<Mutex<Connection>>,
}

Fields

conn: Arc<Mutex<Connection>>

Implementations

impl Store

pub fn open(path: &Path) -> Result<Self>

pub fn memory() -> Result<Self>

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

pub fn fetch_recent_results( &self, suite: &str, limit: u32, ) -> Result<Vec<TestResultRow>>

pub fn fetch_results_for_last_n_runs( &self, suite: &str, n: u32, ) -> Result<Vec<TestResultRow>>

pub fn get_latest_run_id(&self, suite: &str) -> Result<Option<i64>>

pub fn fetch_results_for_run(&self, run_id: i64) -> Result<Vec<TestResultRow>>

pub fn get_last_passing_by_fingerprint( &self, fingerprint: &str, ) -> Result<Option<TestResultRow>>

pub fn insert_run(&self, suite: &str) -> Result<i64>

pub fn create_run(&self, cfg: &EvalConfig) -> Result<i64>

pub fn finalize_run(&self, run_id: i64, status: &str) -> Result<()>

pub fn insert_result_embedded( &self, run_id: i64, row: &TestResultRow, attempts: &[AttemptRow], output: &LlmResponse, ) -> Result<()>

pub fn quarantine_get_reason( &self, suite: &str, test_id: &str, ) -> Result<Option<String>>

pub fn quarantine_add( &self, suite: &str, test_id: &str, reason: &str, ) -> Result<()>

pub fn quarantine_remove(&self, suite: &str, test_id: &str) -> Result<()>

pub fn cache_get(&self, key: &str) -> Result<Option<LlmResponse>>

pub fn cache_put(&self, key: &str, resp: &LlmResponse) -> Result<()>

pub fn get_embedding(&self, key: &str) -> Result<Option<(String, Vec<f32>)>>

pub fn put_embedding(&self, key: &str, model: &str, vec: &[f32]) -> Result<()>

pub fn stats_best_effort(&self) -> Result<StoreStats>

pub fn get_episode_graph( &self, run_id: i64, test_id: &str, ) -> Result<EpisodeGraph>

pub fn insert_event( &self, event: &TraceEvent, run_id: Option<i64>, test_id: Option<&str>, ) -> Result<()>

pub fn insert_batch( &self, events: &[TraceEvent], run_id: Option<i64>, test_id: Option<&str>, ) -> Result<()>

pub fn count_rows(&self, table: &str) -> Result<i64>

impl Store

pub fn get_latest_episode_graph_by_test_id( &self, test_id: &str, ) -> Result<EpisodeGraph>

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

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

Performs copy-assignment from source.