Struct SemanticRouter 

pub struct SemanticRouter { /* private fields */ }

Semantic router that maintains a centroid cache per namespace.

Implementations

impl SemanticRouter

pub fn new(config: SemanticRouterConfig) -> Self

pub fn route( &self, query: &[f32], top_k: usize, min_similarity: f32, ) -> Vec<RouteMatch>

Route a query embedding to the most relevant namespaces.

Returns namespaces sorted by similarity (descending), filtered by min_similarity.

pub async fn refresh_centroids(&self, storage: &Arc<dyn VectorStorage>)

Refresh the centroid cache by sampling memories from each agent namespace.

For each _dakera_agent_* namespace, sample up to sample_size vectors, average their embeddings into a single centroid.

pub fn spawn_refresh( router: Arc<SemanticRouter>, storage: Arc<dyn VectorStorage>, ) -> JoinHandle<()>

Spawn the centroid refresh as a background tokio task.