Struct FileManagedStateStore 

pub struct FileManagedStateStore { /* private fields */ }

Records each session as one JSON file under a directory.

The first store here that reports Durability::CrashDurable: a write is fsynced through a temporary file and a rename, so another process can reconstruct a session after loss. InMemoryManagedStateStore cannot, and says so.

One file per session rather than one file for all of them, so two sessions being checkpointed at once do not contend, and a corrupt write can only lose the session it belonged to.

Example

use adk_managed::state_store::{Durability, FileManagedStateStore, ManagedStateStore};

let store = FileManagedStateStore::new("/var/lib/adk/sessions");
assert_eq!(store.durability(), Durability::CrashDurable);

Implementations

impl FileManagedStateStore

pub fn new(root: impl Into<PathBuf>) -> Self

Records sessions under root, creating it on the first write.

Trait Implementations

impl Debug for FileManagedStateStore

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

Formats the value using the given formatter.

impl ManagedStateStore for FileManagedStateStore

fn durability(&self) -> Durability

What this store guarantees after process loss.

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

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

Records the state of session_id, replacing any previous snapshot.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ManagedSessionState>, RuntimeError>> + Send + 'async_trait>>

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

The recorded state for session_id, or None when nothing is stored.

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

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

Removes any state for session_id.

fn session_ids<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, RuntimeError>> + Send + 'async_trait>>

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

The sessions this store holds state for.