Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory implementation of MessageStore and StateStore. Useful for testing and simple use cases.

Cloning shares the same underlying message/state maps (mirroring InMemoryEventStore’s shared-journal semantics). This matters because the agent builder takes its stores by value: hand the builder a clone and keep the original, and the kept handle still observes everything the agent records. Without shared handles, history written through the builder’s copy would be permanently unreachable to the caller.

Implementations

impl InMemoryStore

pub fn new() -> InMemoryStore

Trait Implementations

impl Clone for InMemoryStore

fn clone(&self) -> InMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl MessageStore for InMemoryStore

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Append a message to the thread’s history

fn get_history<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Get all messages for a thread

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Clear all messages for a thread

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

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Replace the entire message history for a thread. Used for context compaction to replace old messages with a summary.

fn count<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

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

Get the message count for a thread

impl StateStore for InMemoryStore

fn save<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 AgentState, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Save the current agent state

fn load<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<Option<AgentState>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Load the most recent state for a thread

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, thread_id: &'life1 ThreadId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemoryStore: 'async_trait,

Delete state for a thread