Struct BlockingSessionStore 

pub struct BlockingSessionStore<S: SessionStore + 'static> { /* private fields */ }

Adapter that wraps a synchronous SessionStore and exposes async methods by running each call via tokio::task::spawn_blocking.

Custom messages are preserved faithfully: save/append snapshot custom messages to their JSON envelope before crossing the thread boundary, and load uses the registry configured at construction time to restore them.

To restore custom messages on load, provide the registry once at construction via BlockingSessionStore::with_registry. A &CustomMessageRegistry reference cannot cross spawn_blocking boundaries, so a per-call registry is not supported.

Concurrent writes to the same session may corrupt the file. Callers are expected to enforce single-writer access.

Implementations

impl<S: SessionStore + 'static> BlockingSessionStore<S>

pub fn new(store: S) -> Self

Create a new blocking adapter wrapping the given session store.

pub fn with_registry(self, registry: Arc<CustomMessageRegistry>) -> Self

Attach a CustomMessageRegistry for deserializing custom messages on load.

Because &CustomMessageRegistry cannot cross spawn_blocking boundaries, the registry must be provided once at construction rather than per call.

impl<S: SessionStore + 'static> BlockingSessionStore<S>

pub fn save( &self, id: &str, meta: &SessionMeta, messages: &[AgentMessage], ) -> SessionStoreFuture<'_, ()>

Persist a session asynchronously, including both LLM and custom messages.

pub fn save_full( &self, id: &str, meta: &SessionMeta, messages: &[AgentMessage], state: &Value, ) -> SessionStoreFuture<'_, SessionMeta>

Persist a session transcript plus its state snapshot asynchronously.

pub fn append( &self, id: &str, messages: &[AgentMessage], ) -> SessionStoreFuture<'_, ()>

Append messages to an existing session asynchronously.

pub fn load( &self, id: &str, ) -> SessionStoreFuture<'_, (SessionMeta, Vec<AgentMessage>)>

Load a session by ID asynchronously.

Custom messages are restored using the registry supplied to BlockingSessionStore::with_registry. Without a registry, custom messages are discarded on load because the blocking adapter has no serialized-wrapper fallback.

pub fn load_full( &self, id: &str, ) -> SessionStoreFuture<'_, (SessionMeta, Vec<AgentMessage>, Option<Value>)>

Load a session transcript plus its state snapshot asynchronously from one backend-defined read boundary.

pub fn list(&self) -> SessionStoreFuture<'_, Vec<SessionMeta>>

List all saved sessions asynchronously.

pub fn delete(&self, id: &str) -> SessionStoreFuture<'_, ()>

Delete a session by ID asynchronously.

pub fn save_state(&self, id: &str, state: &Value) -> SessionStoreFuture<'_, ()>

Save session state snapshot asynchronously.

pub fn load_state(&self, id: &str) -> SessionStoreFuture<'_, Option<Value>>

Load session state snapshot asynchronously. Returns None if not set.

pub fn save_interrupt( &self, id: &str, state: &InterruptState, ) -> SessionStoreFuture<'_, ()>

Persist interrupt state for a session asynchronously.

pub fn load_interrupt( &self, id: &str, ) -> SessionStoreFuture<'_, Option<InterruptState>>

Load interrupt state for a session asynchronously.

pub fn clear_interrupt(&self, id: &str) -> SessionStoreFuture<'_, ()>

Clear interrupt state for a session asynchronously.

pub fn load_with_options( &self, id: &str, options: &LoadOptions, ) -> SessionStoreFuture<'_, (SessionMeta, Vec<SessionEntry>)>

Load a session with filtering options asynchronously.

pub fn search( &self, query: &str, options: &SessionSearchOptions, ) -> SessionStoreFuture<'_, Vec<SessionHit>>

Search persisted sessions asynchronously.