Struct GraphQuery 

pub struct GraphQuery<'a> { /* private fields */ }

Builder-style queries scoped to one agent_id (matches json_extract(payload, '$.agent_id')).

Implementations

impl<'a> GraphQuery<'a>

pub fn episodes(&self) -> Result<Vec<AinlMemoryNode>, String>

pub fn semantic_nodes(&self) -> Result<Vec<AinlMemoryNode>, String>

pub fn procedural_nodes(&self) -> Result<Vec<AinlMemoryNode>, String>

pub fn persona_nodes(&self) -> Result<Vec<AinlMemoryNode>, String>

pub fn recent_episodes( &self, limit: usize, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn since( &self, ts: DateTime<Utc>, node_type: &str, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn subgraph_edges(&self) -> Result<Vec<SnapshotEdge>, String>

All directed edges whose both endpoints are nodes for this agent_id (same rule as SqliteGraphStore::export_graph).

pub fn neighbors( &self, node_id: Uuid, edge_type: &str, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn lineage(&self, node_id: Uuid) -> Result<Vec<AinlMemoryNode>, String>

pub fn by_tag(&self, tag: &str) -> Result<Vec<AinlMemoryNode>, String>

pub fn by_topic_cluster( &self, cluster: &str, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn pattern_by_name( &self, name: &str, ) -> Result<Option<AinlMemoryNode>, String>

pub fn active_patches(&self) -> Result<Vec<AinlMemoryNode>, String>

pub fn successful_episodes( &self, limit: usize, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn episodes_with_tool( &self, tool_name: &str, limit: usize, ) -> Result<Vec<AinlMemoryNode>, String>

pub fn evolved_persona(&self) -> Result<Option<AinlMemoryNode>, String>

pub fn read_runtime_state(&self) -> Result<Option<RuntimeStateNode>, String>

Latest persisted RuntimeStateNode for this query’s agent_id.