Struct InMemoryStore 

pub struct InMemoryStore<E: Episode> { /* private fields */ }

Append-only in-memory episode store with deterministic lexical retrieval.

E is the caller’s episode payload; only Episode::summary is inspected during retrieval.

Implementations

impl<E: Episode> InMemoryStore<E>

pub fn new() -> Arc<Self>

Create a fresh store wrapped in Arc for cheap cloning across agent tasks.

pub async fn append(&self, episode: E) -> Result<String, PolicyError>

Append a new episode and return its storage key.

Keys are stable across the lifetime of the store and follow the ep-{:016x} template so they sort lexicographically by insertion order. If the process appends more than u64::MAX episodes, the key counter saturates and subsequent appends reuse the terminal key.

pub async fn retrieve_similar( &self, query: &str, k: usize, ) -> Result<Vec<InMemoryHit<E>>, PolicyError>

Return up to k episodes most similar to query, sorted by descending lexical score. Hits with score 0.0 are skipped.

pub async fn get(&self, key: &str) -> Result<E, PolicyError>

Direct lookup by storage key.

pub async fn len(&self) -> Result<usize, PolicyError>

Number of episodes currently stored.

pub async fn is_empty(&self) -> Result<bool, PolicyError>

Whether the store is empty.

Trait Implementations

impl<E: Debug + Episode> Debug for InMemoryStore<E>

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

Formats the value using the given formatter.

impl<E: Episode> Default for InMemoryStore<E>

fn default() -> Self

Returns the “default value” for a type.