Struct CompactingMemory 

pub struct CompactingMemory { /* private fields */ }

Implementations

impl CompactingMemory

pub fn new( summarizer: Arc<dyn Summarizer>, config: CompactingMemoryConfig, ) -> Self

pub fn with_default_config(summarizer: Arc<dyn Summarizer>) -> Self

pub fn config(&self) -> &CompactingMemoryConfig

pub fn summary(&self) -> Option<String>

pub fn summarized_count(&self) -> usize

pub fn compression_history(&self) -> Vec<CompressionEvent>

Trait Implementations

impl Memory for CompactingMemory

fn add_message<'life0, 'async_trait>( &'life0 self, message: ChatMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Append a message to conversation history.

fn get_messages<'life0, 'async_trait>( &'life0 self, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChatMessage>>> + Send + 'async_trait>>

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

Get messages. Some(n) returns the most recent N messages.

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

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

Remove all messages and reset state.

fn len(&self) -> usize

Number of messages currently stored.

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

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

Serialize current state for persistence.

fn restore<'life0, 'async_trait>( &'life0 self, snapshot: MemorySnapshot, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Restore from a previously saved snapshot, replacing current state.

fn evict_oldest<'life0, 'async_trait>( &'life0 self, count: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChatMessage>>> + Send + 'async_trait>>

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

Remove the oldest N messages. Returns empty vec by default.

fn is_empty(&self) -> bool

Returns true if no messages are stored.

impl Memory for CompactingMemory

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

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

fn compress<'life0, 'life1, 'async_trait>( &'life0 self, summarizer: Option<&'life1 dyn Summarizer>, ) -> Pin<Box<dyn Future<Output = Result<CompressResult>> + Send + 'async_trait>>

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

fn needs_compression(&self) -> bool