Struct PersistentMemory 

pub struct PersistentMemory { /* private fields */ }

Write-through memory that persists turns to a MemoryStore and caches them in-process.

Implementations

impl PersistentMemory

pub fn new( session_id: impl Into<String>, app_name: impl Into<String>, user_id: impl Into<String>, store: Arc<dyn MemoryStore>, ) -> Self

Unbounded persistent memory.

pub fn windowed( session_id: impl Into<String>, app_name: impl Into<String>, user_id: impl Into<String>, store: Arc<dyn MemoryStore>, n: usize, ) -> Self

Windowed persistent memory — only the last n turns are kept in the in-process cache. Older turns are still in the backing store but won’t be injected into prompts.

pub async fn hydrate(&mut self) -> Result<(), StoreError>

Load all turns from the backing store into the in-process cache. Idempotent — subsequent calls are no-ops once hydrated.

pub async fn push_turn_async( &mut self, turn: MemoryTurn, ) -> Result<(), StoreError>

Append a turn to the cache and persist it to the backing store.

pub async fn clear_store(&mut self) -> Result<(), StoreError>

Clear the in-process cache and delete all turns from the backing store.

Trait Implementations

impl Debug for PersistentMemory

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

Formats the value using the given formatter.

impl Memory for PersistentMemory

fn push_turn(&mut self, turn: MemoryTurn)

Synchronous push — appends to the in-process cache only. Note: this does not persist to the backing store. Use push_turn_async in async contexts to ensure write-through persistence.

fn as_any_mut(&mut self) -> Option<&mut dyn Any>

Enables downcasting to concrete types (e.g., PersistentMemory). Override in concrete types to support downcast_mut.

fn messages(&self) -> Vec<MessageNum>

Returns messages in chronological order (oldest first).

fn clear(&mut self)

fn len(&self) -> usize

fn is_empty(&self) -> bool