Struct SqliteRuntimeStore 

pub struct SqliteRuntimeStore { /* private fields */ }

SQLite-backed RuntimeStore implementation used by default.

Implementations

impl SqliteRuntimeStore

pub fn default_path() -> PathBuf

Returns the default SQLite path used when no explicit store path is provided.

pub fn default_directory() -> PathBuf

Returns the default directory used for Mentra runtime stores.

pub fn for_runtime_identifier(runtime_identifier: &str) -> Self

Creates a SQLite runtime store in the default directory using a runtime-scoped filename.

pub fn path_for_runtime_identifier(runtime_identifier: &str) -> PathBuf

Returns the default SQLite path for a specific runtime identifier.

pub fn list_persisted_runtime_identifiers() -> Result<Vec<String>, RuntimeError>

Lists runtime identifiers that have persisted SQLite stores in the default directory.

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

Creates a SQLite runtime store at the provided path.

pub fn path(&self) -> &Path

Returns the SQLite database path for the store.

Trait Implementations

impl AgentStore for SqliteRuntimeStore

fn prepare_recovery(&self) -> Result<(), RuntimeError>

fn create_agent( &self, record: &PersistedAgentRecord, memory: &AgentMemoryState, ) -> Result<(), RuntimeError>

fn save_agent_record( &self, record: &PersistedAgentRecord, ) -> Result<(), RuntimeError>

fn save_agent_memory( &self, agent_id: &str, memory: &AgentMemoryState, ) -> Result<(), RuntimeError>

fn load_agent( &self, agent_id: &str, ) -> Result<Option<LoadedAgentState>, RuntimeError>

fn list_agents(&self) -> Result<Vec<LoadedAgentState>, RuntimeError>

fn list_agents_by_runtime( &self, runtime_identifier: &str, ) -> Result<Vec<LoadedAgentState>, RuntimeError>

impl AuditStore for SqliteRuntimeStore

fn record_audit_event( &self, scope: &str, event_type: &str, payload: Value, ) -> Result<(), RuntimeError>

impl BackgroundStore for SqliteRuntimeStore

fn load_background_tasks( &self, agent_id: &str, ) -> Result<Vec<BackgroundTaskSummary>, RuntimeError>

fn upsert_background_task( &self, agent_id: &str, task: &BackgroundTaskSummary, notification_state: i64, ) -> Result<(), RuntimeError>

fn drain_background_notifications( &self, agent_id: &str, ) -> Result<Vec<BackgroundNotification>, RuntimeError>

fn has_pending_background_notifications( &self, agent_id: &str, ) -> Result<bool, RuntimeError>

fn has_deliverable_background_notifications( &self, agent_id: &str, ) -> Result<bool, RuntimeError>

fn ack_background_notifications( &self, agent_id: &str, ) -> Result<(), RuntimeError>

fn requeue_background_notifications( &self, agent_id: &str, ) -> Result<(), RuntimeError>

impl Clone for SqliteRuntimeStore

fn clone(&self) -> SqliteRuntimeStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for SqliteRuntimeStore

fn default() -> Self

Returns the “default value” for a type.

impl LeaseStore for SqliteRuntimeStore

fn acquire_lease( &self, key: &str, owner: &str, ttl: Duration, ) -> Result<bool, RuntimeError>

fn release_lease(&self, key: &str, owner: &str) -> Result<(), RuntimeError>

impl MemoryStore for SqliteRuntimeStore

fn upsert_records(&self, records: &[MemoryRecord]) -> Result<(), RuntimeError>

fn search_records_with_options( &self, request: &MemorySearchRequest, ) -> Result<Vec<MemoryRecord>, RuntimeError>

fn delete_records(&self, record_ids: &[String]) -> Result<(), RuntimeError>

fn tombstone_records( &self, agent_id: &str, record_ids: &[String], ) -> Result<usize, RuntimeError>

fn load_agent_memory_cursor( &self, agent_id: &str, ) -> Result<Option<MemoryCursor>, RuntimeError>

fn save_agent_memory_cursor( &self, agent_id: &str, cursor: &MemoryCursor, ) -> Result<(), RuntimeError>

fn search_records( &self, agent_id: &str, query: &str, limit: usize, ) -> Result<Vec<MemoryRecord>, RuntimeError>

impl PermissionRuleStore for SqliteRuntimeStore

fn save_rules( &self, session_id: &str, project_id: Option<&str>, rules: &[RememberedRule], ) -> Result<(), RuntimeError>

Persists the provided permission rules for a session, replacing any existing session-scoped rules. project_id is stored alongside each rule so that project-scoped rules can later be retrieved by other sessions that share the same project.

fn load_rules( &self, session_id: &str, project_id: Option<&str>, ) -> Result<Vec<RememberedRule>, RuntimeError>

Loads all persisted permission rules that apply to the given session.

fn clear_rules(&self, session_id: &str) -> Result<(), RuntimeError>

Removes all persisted permission rules for a session.

impl RunStore for SqliteRuntimeStore

fn start_run(&self, agent_id: &str) -> Result<String, RuntimeError>

fn update_run_state( &self, run_id: &str, state: &str, error: Option<&str>, ) -> Result<(), RuntimeError>

fn finish_run(&self, run_id: &str) -> Result<(), RuntimeError>

fn fail_run(&self, run_id: &str, error: &str) -> Result<(), RuntimeError>

impl TaskStore for SqliteRuntimeStore

fn load_tasks(&self, namespace: &Path) -> Result<Vec<TaskItem>, RuntimeError>

fn capture_tasks( &self, namespace: &Path, ) -> Result<TaskStateSnapshot, RuntimeError>

fn restore_tasks( &self, namespace: &Path, snapshot: &TaskStateSnapshot, ) -> Result<(), RuntimeError>

fn replace_tasks( &self, namespace: &Path, tasks: &[TaskItem], ) -> Result<(), RuntimeError>