Struct InMemoryStore 

pub struct InMemoryStore<E>
where
    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> InMemoryStore<E>

where E: Episode,

pub fn new() -> Arc<InMemoryStore<E>>

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 for InMemoryStore<E>

where E: Debug + Episode,

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

Formats the value using the given formatter.

impl<E> Default for InMemoryStore<E>

where E: Episode,

fn default() -> InMemoryStore<E>

Returns the “default value” for a type.