Struct MemoryCompressor 

pub struct MemoryCompressor { /* private fields */ }

Memory compressor

Implementations

impl MemoryCompressor

pub fn new(storage: Arc<dyn Memory>, config: CompressionConfig) -> Self

Create a new memory compressor

pub fn needs_compression(&self, stats: &MemoryStats) -> bool

Check if compression is needed based on stats

pub async fn calculate_stats(&self, namespace: &str) -> RragResult<MemoryStats>

Calculate memory statistics for a namespace

pub async fn compress_conversation_memory( &self, namespace: &str, llm_client: &Client, keep_recent_count: usize, ) -> RragResult<usize>

Available on crate feature rexis-llm-client only.

Compress conversation memory by summarizing old messages (requires ‘rsllm-client’ feature)

pub async fn remove_old_items( &self, namespace: &str, older_than: DateTime<Utc>, ) -> RragResult<usize>

Remove old items based on timestamp

pub async fn remove_least_important( &self, namespace: &str, min_importance: f64, max_to_remove: usize, ) -> RragResult<usize>

Remove least important items