Struct ContextQueryService 

pub struct ContextQueryService { /* private fields */ }

Implementations

impl ContextQueryService

pub fn new(store: Arc<dyn NodeStore>) -> Self

Create a context query service over the shared node store.

pub async fn get_context_async( &self, session_id: &str, stability: f32, friction: f32, logic: f32, autonomy: f32, limit: usize, ) -> RetrieveResult

pub async fn get_context_global_async( &self, stability: f32, friction: f32, logic: f32, autonomy: f32, limit: usize, ) -> RetrieveResult

Retrieve context across all sessions (global memory mode).

pub async fn get_context_global_filtered_async( &self, stability: f32, friction: f32, logic: f32, autonomy: f32, from_utc: Option<DateTime<Utc>>, to_utc: Option<DateTime<Utc>>, tiers: Option<&[String]>, limit: usize, ) -> RetrieveResult

pub async fn get_context_scoped_async( &self, session_id: Option<&str>, stability: f32, friction: f32, logic: f32, autonomy: f32, limit: usize, ) -> RetrieveResult

Retrieve context with an optional session scope.

pub async fn get_context_scoped_filtered_async( &self, session_id: Option<&str>, stability: f32, friction: f32, logic: f32, autonomy: f32, from_utc: Option<DateTime<Utc>>, to_utc: Option<DateTime<Utc>>, tiers: Option<&[String]>, limit: usize, ) -> RetrieveResult

Retrieve resonance-ranked context with optional scope and tier/date filters.

pub async fn get_context_hybrid_async( &self, session_id: &str, stability: f32, friction: f32, logic: f32, autonomy: f32, query_embedding: Option<&[f32]>, alpha: f32, beta: f32, limit: usize, ) -> RetrieveResult

pub async fn get_context_hybrid_global_async( &self, stability: f32, friction: f32, logic: f32, autonomy: f32, query_embedding: Option<&[f32]>, alpha: f32, beta: f32, limit: usize, ) -> RetrieveResult

Retrieve hybrid context across all sessions (global memory mode).

pub async fn get_context_hybrid_global_filtered_async( &self, stability: f32, friction: f32, logic: f32, autonomy: f32, from_utc: Option<DateTime<Utc>>, to_utc: Option<DateTime<Utc>>, tiers: Option<&[String]>, query_embedding: Option<&[f32]>, alpha: f32, beta: f32, limit: usize, ) -> RetrieveResult

pub async fn get_context_hybrid_scoped_async( &self, session_id: Option<&str>, stability: f32, friction: f32, logic: f32, autonomy: f32, query_embedding: Option<&[f32]>, alpha: f32, beta: f32, limit: usize, ) -> RetrieveResult

Retrieve hybrid context with an optional session scope.

pub async fn get_context_hybrid_scoped_filtered_async( &self, session_id: Option<&str>, stability: f32, friction: f32, logic: f32, autonomy: f32, from_utc: Option<DateTime<Utc>>, to_utc: Option<DateTime<Utc>>, tiers: Option<&[String]>, query_embedding: Option<&[f32]>, alpha: f32, beta: f32, limit: usize, ) -> RetrieveResult

Retrieve hybrid-ranked context with optional scope and tier/date filters.

pub async fn list_nodes_async( &self, limit: usize, session_id: Option<&str>, ) -> Result<ListNodesResult>