Struct FeedbackStore 

pub struct FeedbackStore {
    pub momentum: HashMap<MemoryId, FeedbackMomentum>,
    /* private fields */
}

Persistent store for feedback momentum with in-memory cache

Fields

momentum: HashMap<MemoryId, FeedbackMomentum>

In-memory cache: memory_id -> FeedbackMomentum

Implementations

impl FeedbackStore

pub fn new() -> Self

Create in-memory only store (no persistence)

pub fn with_shared_db(db: Arc<DB>, base_path: &Path) -> Result<Self>

Create persistent store backed by a shared RocksDB instance.

The caller is responsible for opening the DB with the CF_FEEDBACK column family already declared. On first use this constructor migrates data from the legacy standalone feedback/ DB directory into the shared CF.

pub fn with_persistence<P: AsRef<Path>>(path: P) -> Result<Self>

Create persistent store with its own standalone RocksDB instance.

Primarily useful for tests and standalone operation. In production, prefer with_shared_db to share a single DB instance.

pub fn get_or_create_momentum( &mut self, memory_id: MemoryId, memory_type: ExperienceType, ) -> &mut FeedbackMomentum

Get or create momentum for a memory

pub fn get_momentum(&self, memory_id: &MemoryId) -> Option<FeedbackMomentum>

Get momentum for a memory (if exists in-memory), with disk fallback. Checks the in-memory HashMap first, then falls back to RocksDB.

pub fn mark_dirty(&mut self, memory_id: &MemoryId)

Mark a memory as dirty (needs persistence)

pub fn set_pending(&mut self, pending: PendingFeedback)

Set pending feedback for a user (also persists to disk)

pub fn take_pending(&mut self, user_id: &str) -> Option<PendingFeedback>

Take pending feedback for a user (removes from store and disk)

pub fn get_pending(&self, user_id: &str) -> Option<&PendingFeedback>

Get pending feedback for a user (without removing)

pub fn cleanup_expired(&mut self)

Clean up expired pending feedback

pub fn set_previous_context( &mut self, user_id: &str, context: String, embedding: Vec<f32>, surfaced_memory_ids: Vec<MemoryId>, )

Set previous context for a user (for repetition/topic change detection) Called when memories are surfaced to track what the user asked

pub fn get_previous_context(&self, user_id: &str) -> Option<&PreviousContext>

Get previous context for a user

pub fn detect_context_pattern( &self, user_id: &str, current_embedding: &[f32], ) -> Option<(bool, bool, f32)>

Compare current context to previous and detect action patterns Returns: (is_repetition, is_topic_change, similarity)

• Repetition: similarity > 0.8 means user is asking same thing again (memories failed)
• Topic change: similarity < 0.3 means user moved on (task might be complete)

pub fn flush(&mut self) -> Result<usize>

Flush dirty entries to disk and ensure WAL is persisted

pub fn database(&self) -> Option<&Arc<DB>>

Get reference to the RocksDB database for backup (if available)

pub fn stats(&self) -> FeedbackStoreStats

Get statistics

Trait Implementations

impl Debug for FeedbackStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FeedbackStore

fn default() -> Self

Returns the “default value” for a type.