Struct RuntimeStore 

pub struct RuntimeStore { /* private fields */ }

Runtime store facade composing session, execution, run, embedding, and artifact stores.

Provides a unified interface for all runtime persistence operations. Individual sub-stores are accessed via their respective accessor methods.

Implementations

impl RuntimeStore

pub fn new( sessions: Box<dyn SessionStore>, executions: Box<dyn ExecutionStore>, runs: Box<dyn RunStore>, ) -> Self

Creates a new runtime store with session, execution, and run stores.

Embedding and artifact stores are optional — attach them with with_embeddings and with_artifacts.

pub fn with_embeddings(self, store: Box<dyn EmbeddingStore>) -> Self

Attaches an optional embedding store for vector search operations.

pub fn with_artifacts(self, store: Box<dyn ArtifactStore>) -> Self

Attaches an optional artifact store for file/blob storage.

pub fn sessions(&self) -> &dyn SessionStore

Returns the session store.

pub fn executions(&self) -> &dyn ExecutionStore

Returns the execution store.

pub fn runs(&self) -> &dyn RunStore

Returns the run store.

pub fn embeddings(&self) -> Option<&dyn EmbeddingStore>

Returns the embedding store, if configured.

pub fn artifacts(&self) -> Option<&dyn ArtifactStore>

Returns the artifact store, if configured.

pub fn from_extensions(exts: &Extensions) -> Self

Creates a RuntimeStore from an Extensions facade, cloning its store extension points. Backed by default in-memory stores when no entries are registered.

pub fn sessions_ep(&self) -> &ExtensionPoint<dyn SessionStore>

Returns the session store extension point.

pub fn executions_ep(&self) -> &ExtensionPoint<dyn ExecutionStore>

Returns the execution store extension point.

pub fn runs_ep(&self) -> &ExtensionPoint<dyn RunStore>

Returns the run store extension point.

pub fn embeddings_ep(&self) -> &ExtensionPoint<dyn EmbeddingStore>

Returns the embedding store extension point.

pub fn artifacts_ep(&self) -> &ExtensionPoint<dyn ArtifactStore>

Returns the artifact store extension point.

pub async fn ensure_session( &self, session_id: Option<Uuid>, ) -> RuntimeResult<Uuid>

Creates or loads a session.

Errors

Returns RuntimeError::SessionNotFound when session_id is provided but does not exist, or RuntimeError::Storage on persistence failure.

pub async fn append_message( &self, session_id: Uuid, message: &Message, ) -> RuntimeResult<Uuid>

Appends a message to a session.

Errors

Returns RuntimeError::Storage on persistence failure.

pub async fn list_messages( &self, session_id: Uuid, ) -> RuntimeResult<Vec<Message>>

Lists messages for a session.

Errors

Returns RuntimeError::Storage on persistence failure.