Struct Storage 

pub struct Storage {
    pub db_path: PathBuf,
    pub content_dim: usize,
    pub trigger_dim: usize,
    /* private fields */
}

Fields

db_path: PathBuf

content_dim: usize

trigger_dim: usize

Implementations

impl Storage

pub fn open( db_path: impl AsRef<Path>, content_dim: usize, trigger_dim: usize, ) -> Result<Self>

pub fn open_readonly(db_path: impl AsRef<Path>) -> Result<Self>

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

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

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

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

pub fn set_meta(&self, key: &str, value: &str) -> Result<()>

pub fn get_meta_or(&self, key: &str, default: &str) -> String

pub fn insert_chunk(&self, c: &ChunkRow) -> Result<()>

pub fn insert_vec_content(&self, chunk_id: &str, emb: &[u8]) -> Result<()>

pub fn insert_vec_trigger(&self, chunk_id: &str, emb: &[u8]) -> Result<()>

pub fn get_chunk(&self, id: &str) -> Result<Option<Value>>

pub fn update_chunk_state( &self, id: &str, state: &str, reason: Option<&str>, now: &str, ) -> Result<()>

pub fn update_chunk_confidence( &self, id: &str, conf: f64, reason: Option<&str>, now: &str, ) -> Result<()>

pub fn update_chunk_last_used(&self, id: &str, now: &str) -> Result<()>

pub fn get_chunk_by_hash(&self, hash: &str) -> Result<Option<Value>>

pub fn search_vec_content( &self, query: &[f32], limit: usize, ) -> Result<Vec<(String, f32)>>

pub fn search_vec_trigger( &self, query: &[f32], limit: usize, ) -> Result<Vec<(String, f32)>>

pub fn is_hash_invalidated(&self, hash: &str) -> Result<bool>

pub fn insert_invalidated_hash( &self, hash: &str, reason: Option<&str>, ts: &str, ) -> Result<()>

pub fn insert_usage_trace( &self, trace_id: &str, chunk_id: Option<&str>, event: &str, strength: f64, similarity: Option<f64>, refine_mode: Option<&str>, tokens: Option<i64>, rank: Option<i64>, source: &str, ts: &str, ) -> Result<()>

pub fn get_outcome_for_trace(&self, trace_id: &str) -> Result<Option<String>>

pub fn purge_usage_trace(&self, before_ts: &str) -> Result<usize>

pub fn upsert_episodic_log(&self, log: &EpisodicLogRow) -> Result<()>

pub fn get_episodic_log(&self, trace_id: &str) -> Result<Option<Value>>

pub fn update_episodic_log_state( &self, trace_id: &str, state: &str, note: Option<&str>, outcome: Option<&str>, ) -> Result<()>

pub fn patch_episodic_log_content( &self, trace_id: &str, query: Option<&str>, output: Option<&str>, output_summary: Option<&str>, nomination: Option<&str>, priority: i64, ) -> Result<()>

Patch content fields on an existing episodic_log row (補写: output_summary, nomination, etc.)

pub fn update_episodic_log_state_by_id( &self, id: &str, state: &str, note: Option<&str>, outcome: Option<&str>, ) -> Result<()>

Update by primary-key id (used after distill where we have the row id, not trace_id).

pub fn update_episodic_log_tokens( &self, id: &str, prompt_tokens: i64, completion_tokens: i64, ) -> Result<()>

pub fn claim_distill_batch( &self, run_id: &str, limit: usize, locked_at: &str, ) -> Result<Vec<Value>>

Claim a batch of ‘new’ logs for distillation: mark them ‘screening’ atomically. Returns the claimed rows (with distill_run_id set to run_id).

pub fn query_episodic_logs_open(&self, limit: usize) -> Result<Vec<Value>>

pub fn query_chunks(&self, sql: &str) -> Result<Vec<Value>>

pub fn query_chunks_params<P: Params>( &self, sql: &str, p: P, ) -> Result<Vec<Value>>

pub fn get_deps( &self, chunk_id: &str, ) -> Result<Vec<(String, String, Option<String>)>>

pub fn get_reverse_deps(&self, chunk_id: &str) -> Result<Vec<String>>

pub fn insert_dep( &self, src: &str, dst: &str, kind: &str, dst_lib: Option<&str>, ) -> Result<()>

pub fn upsert_chunk_success_trace( &self, chunk_id: &str, trace_id: &str, ts: &str, ) -> Result<()>

pub fn attach_shared(&self, path: &str, alias: &str) -> Result<()>

pub fn lib_id(&self) -> Result<String>

pub fn execute(&self, sql: &str) -> Result<()>

pub fn conn_execute<P: Params>(&self, sql: &str, p: P) -> Result<()>

Execute a parameterised statement (not batch); returns rows-affected count.