Struct TopicIndexService 

pub struct TopicIndexService {
    topics: Arc<RwLock<HashMap<String, Vec<MemoryId>>>>,
    topic_namespaces: Arc<RwLock<HashMap<String, Vec<Namespace>>>>,
    last_refresh: Arc<RwLock<Option<Instant>>>,
    refresh_interval: Duration,
}

Service for maintaining topic → memory mappings.

Fields

topics: Arc<RwLock<HashMap<String, Vec<MemoryId>>>>

Topic to memory ID mappings.

topic_namespaces: Arc<RwLock<HashMap<String, Vec<Namespace>>>>

Topic to namespace mappings.

last_refresh: Arc<RwLock<Option<Instant>>>

Last refresh timestamp.

refresh_interval: Duration

Refresh interval.

Implementations

impl TopicIndexService

pub fn new() -> Self

Creates a new topic index service.

pub const fn with_refresh_interval(self, interval: Duration) -> Self

Sets the refresh interval.

pub fn needs_refresh(&self) -> bool

Checks if the index needs refreshing.

pub fn build_index(&self, recall: &RecallService) -> Result<()>

Builds the topic index from a recall service.

Extracts topics from:

• Memory tags
• Memory namespace names
• Keywords in memory content

Errors

Returns an error if memory retrieval fails.

pub fn list_topics(&self) -> Result<Vec<TopicInfo>>

Lists all topics with their metadata.

Errors

Returns an error if the lock is poisoned.

pub fn get_topic_memories(&self, topic: &str) -> Result<Vec<MemoryId>>

Gets memory IDs for a specific topic.

Errors

Returns an error if the lock is poisoned.

pub fn get_topic_info(&self, topic: &str) -> Result<Option<TopicInfo>>

Gets topic info for a specific topic.

Errors

Returns an error if the lock is poisoned.

pub fn add_memory( &self, memory_id: &MemoryId, tags: &[String], namespace: Namespace, ) -> Result<()>

Adds a memory to the topic index.

Call this when a new memory is captured to keep the index up to date.

Errors

Returns an error if the lock is poisoned.

pub fn topic_count(&self) -> usize

Returns the number of topics in the index.

pub fn association_count(&self) -> usize

Returns the total number of topic-memory associations.

pub fn remove_memory(&self, memory_id: &MemoryId) -> Result<()>

Removes a memory from the topic index (PERF-M1: incremental updates).

Call this when a memory is deleted to keep the index up to date without requiring a full rebuild.

Errors

Returns an error if the lock is poisoned.

pub fn update_memory( &self, memory_id: &MemoryId, new_tags: &[String], new_namespace: Namespace, ) -> Result<()>

Updates a memory in the topic index (PERF-M1: incremental updates).

This is a convenience method that removes the old entry and adds the new one. Use this when tags or namespace change.

Errors

Returns an error if the lock is poisoned.

pub fn add_content_keywords( &self, memory_id: &MemoryId, content: &str, namespace: Namespace, ) -> Result<()>

Adds content-based keywords to the topic index (PERF-M1: incremental updates).

Call this after add_memory() to also index keywords from the memory content. This is separated to allow callers to control whether content keywords are indexed.

Errors

Returns an error if the lock is poisoned.

pub fn clear(&self) -> Result<()>

Clears the entire topic index.

Use before a full rebuild or when resetting state.

Errors

Returns an error if the lock is poisoned.

Trait Implementations

impl Default for TopicIndexService

fn default() -> Self

Returns the “default value” for a type.