Struct ExperienceStore 

pub struct ExperienceStore { /* private fields */ }

Persistent store for experience memory nodes and edges.

Wraps the experience_nodes, experience_edges, and experience_entity_links tables created by migration 076_experience_memory.sql.

Implementations

impl ExperienceStore

pub fn new(pool: DbPool) -> Self

Create a new experience store using the provided connection pool.

pub async fn record_tool_outcome( &self, session_id: &str, turn: i64, tool_name: &str, outcome: &str, detail: Option<&str>, error_ctx: Option<&str>, ) -> Result<i64, MemoryError>

Record a tool execution outcome as an experience node.

Returns the row ID of the newly inserted experience node.

Errors

Returns MemoryError if the database insert fails.

Examples

let id = store
    .record_tool_outcome("session-1", 3, "shell", "success", Some("exit 0"), None)
    .await?;

pub async fn link_to_entities( &self, experience_id: i64, entity_ids: &[i64], ) -> Result<(), MemoryError>

Link an experience node to one or more knowledge graph entities.

Uses INSERT OR IGNORE to tolerate duplicate links gracefully.

Errors

Returns MemoryError if any database insert fails.

pub async fn link_sequential( &self, prev: i64, next: i64, ) -> Result<(), MemoryError>

Record a sequential followed_by link between two experience nodes.

Errors

Returns MemoryError if the database insert fails.

pub async fn evolution_sweep( &self, graph_store: &GraphStore, confidence_threshold: f32, ) -> Result<EvolutionSweepStats, MemoryError>

Run a graph evolution sweep on the knowledge graph.

Performs two pruning passes on the graph_edges table via graph_store:

1. Removes self-loops (source_entity_id = target_entity_id).
2. Removes low-confidence edges with zero retrievals that have no expiry set.

This is a maintenance operation; it never blocks the agent loop.

Errors

Returns MemoryError if any database operation fails.