Struct CompressedMemory 

pub struct CompressedMemory<M: Memory> { /* private fields */ }

A memory decorator that compresses older messages into summaries.

When the message count exceeds threshold, older messages (except the system prompt) are replaced with a single summary message, keeping only the most recent keep_recent messages intact.

The summary is generated by concatenating message content (for simplicity and zero-dependency). For LLM-powered summarization, use a custom strategy by wrapping this decorator with a provider call.

Implementations

impl<M: Memory> CompressedMemory<M>

pub fn new(inner: M, threshold: usize, keep_recent: usize) -> Self

Create a new compressed memory wrapping the given inner memory.

• threshold: Trigger compression when message count exceeds this
• keep_recent: Number of most recent messages to preserve uncompressed

pub fn threshold(&self) -> usize

Get the compression threshold.

pub fn keep_recent(&self) -> usize

Get the number of recent messages kept uncompressed.

Trait Implementations

impl<M: Memory> Memory for CompressedMemory<M>

fn messages<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get conversation messages for a session.

fn append<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, message: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append a message to the conversation history.

fn get_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get a value from working memory.

fn set_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Set a value in working memory.

fn recall<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Search for relevant memories.

fn store<'life0, 'async_trait>( &'life0 self, entry: MemoryEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store a new memory entry.

fn create_session<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new session and return its ID.

fn list_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all known session IDs.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a session and all associated conversation history and working memory.