Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

Implementations

impl InMemoryStore

pub fn new(max_messages: usize) -> Self

pub fn max_messages(&self) -> usize

Trait Implementations

impl Clone for InMemoryStore

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Memory for InMemoryStore

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 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.

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

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

Serialize current state for persistence.

impl Memory for InMemoryStore

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

where Self: Sync + '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: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn needs_compression(&self) -> bool