Struct InMemory 

pub struct InMemory { /* private fields */ }

In-memory store backed by Arc<Mutex<Vec<(String, String)>>>.

Clone is cheap — clones share the same underlying storage.

Implementations

impl InMemory

pub fn new() -> InMemory

Create an empty store.

pub fn with_entries( entries: impl IntoIterator<Item = (String, String)>, ) -> InMemory

Create a store pre-populated with entries.

Trait Implementations

impl Clone for InMemory

fn clone(&self) -> InMemory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemory

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for InMemory

fn default() -> InMemory

Returns the “default value” for a type.

impl Hook for InMemory

fn on_build_agent(&self, config: AgentConfig) -> AgentConfig

Called by Runtime::add_agent() before building the Agent.

fn on_register_tools( &self, registry: &mut ToolRegistry, ) -> impl Future<Output = ()> + Send

Called by Runtime::new() to register tools into the shared registry.

fn on_event(&self, _agent: &str, _event: &AgentEvent)

Called by Runtime after each agent step during execution.

impl Memory for InMemory

fn get(&self, key: &str) -> Option<String>

Get the value for a key (owned).

fn entries(&self) -> Vec<(String, String)>

Get all key-value pairs (owned).

fn set( &self, key: impl Into<String>, value: impl Into<String>, ) -> Option<String>

Set (upsert) a key-value pair. Returns the previous value if the key existed.

fn remove(&self, key: &str) -> Option<String>

Remove a key. Returns the removed value if it existed.

fn compile(&self) -> String

Compile all entries into a string for system prompt injection.

fn store( &self, key: impl Into<String> + Send, value: impl Into<String> + Send, ) -> impl Future<Output = Result<(), Error>> + Send

Store a key-value pair (async). Default delegates to set.

fn recall( &self, _query: &str, _options: RecallOptions, ) -> impl Future<Output = Result<Vec<MemoryEntry>, Error>> + Send

Search for relevant entries (async). Default returns empty.

fn compile_relevant(&self, _query: &str) -> impl Future<Output = String> + Send

Compile relevant entries for a query (async). Default delegates to compile.