Struct PatternStore 

pub struct PatternStore { /* private fields */ }

SQLite-backed tool invocation pattern store for PASTE.

Thread-safe via Arc. Call observe after each tool completion and predict at skill activation to get speculative candidates.

Examples

let store = PatternStore::new(pool, 14.0);
store.observe("my-skill", "abc123", None, "bash",
    r#"{"command":"ls"}"#, ToolOutcome::Success, 42).await?;
let predictions = store.predict("my-skill", "abc123", None, 3).await?;

Implementations

impl PatternStore

pub fn new(pool: DbPool, half_life_days: f64) -> Self

Create a new pattern store.

half_life_days controls the exponential decay; 14 days is the default.

pub fn with_min_observations(self, n: u32) -> Self

Set the minimum number of raw observations required before predicting.

pub async fn observe( &self, skill_name: &str, skill_hash: &str, prev_tool: Option<&str>, next_tool: &str, args_json: &str, outcome: ToolOutcome, latency_ms: u64, ) -> Result<(), PatternError>

Record a completed tool invocation.

Updates count_decayed using the exponential decay formula (computed in Rust, not via pow() in SQLite — pow requires SQLITE_ENABLE_MATH_FUNCTIONS which is not available in bundled libsqlite3-sys) and appends to success_raw / count_raw. Also triggers a debounced refresh.

Errors

Returns PatternError::Db on SQLite failure.

pub async fn predict( &self, skill_name: &str, skill_hash: &str, prev_tool: Option<&str>, k: u8, ) -> Result<Vec<Prediction>, PatternError>

Return the top-k predicted next tool calls for (skill, prev_tool).

Only returns predictions with wilson_lower_bound >= 0.5 and count_raw >= min_observations.

Errors

Returns PatternError::Db on SQLite failure.

pub async fn refresh( &self, skill_name: &str, skill_hash: &str, prev_tool: Option<&str>, ) -> Result<(), PatternError>

Recompute and materialize predictions for (skill, skill_hash, prev_tool).

Debounced to at most once per 60 s per (skill_hash, prev_tool). Runs DELETE + N INSERTs inside a single transaction (H3: atomic refresh).

Errors

Returns PatternError::Db on SQLite failure.

pub async fn vacuum(&self) -> Result<u64, PatternError>

Purge tool_pattern_transitions rows with stale skill_hash older than 30 days.

Errors

Returns PatternError::Db on SQLite failure.