Struct StateStore 

pub struct StateStore {
    pub base_path: PathBuf,
}

A filesystem-based persistent state store.

Files are organized as <base_path>/<category>/<name>.md or <base_path>/<category>/<name>.json.

Fields

base_path: PathBuf

Root directory for all state files.

Implementations

impl StateStore

pub fn new(base_path: PathBuf) -> Result<Self>

Creates a new state store, initializing the directory if needed.

Example

use oxios_kernel::state_store::StateStore;
use std::path::PathBuf;

let store = StateStore::new(PathBuf::from("/tmp/oxios-state")).unwrap();

pub async fn save_markdown( &self, category: &str, name: &str, content: &str, ) -> Result<()>

Save a markdown file under the given category.

pub async fn load_markdown( &self, category: &str, name: &str, ) -> Result<Option<String>>

Load a markdown file from the given category.

pub async fn list_category(&self, category: &str) -> Result<Vec<String>>

List all markdown files in a category (names without extension).

pub async fn save_json<T: Serialize>( &self, category: &str, name: &str, data: &T, ) -> Result<()>

Save a serializable value as JSON under the given category.

pub async fn load_json<T: DeserializeOwned>( &self, category: &str, name: &str, ) -> Result<Option<T>>

Load a deserializable value from JSON in the given category.

pub async fn delete_file(&self, category: &str, name: &str) -> Result<bool>

Delete a file from the given category.

impl StateStore

pub async fn save_session(&self, session: &Session) -> Result<()>

Saves a session to the sessions category.

pub async fn save_session_with_prune( &self, session: &Session, prune_config: &PruneConfig, ) -> Result<()>

Saves a session and then runs pruning if auto_prune is enabled.

pub async fn load_session( &self, session_id: &SessionId, ) -> Result<Option<Session>>

Loads a session by ID.

pub async fn list_sessions(&self) -> Result<Vec<SessionSummary>>

Lists all sessions (sorted by updated_at descending).

pub async fn delete_session(&self, session_id: &SessionId) -> Result<bool>

Deletes a session by ID.

pub async fn get_or_create_session( &self, user_id: &str, session_id: Option<&SessionId>, ) -> Result<Session>

Gets or creates a session for a user, initializing with the given session ID.

pub async fn update_session(&self, session: &Session) -> Result<()>

Updates an existing session, saving it to disk.

pub async fn prune_sessions(&self, config: &PruneConfig) -> Result<usize>

Prune sessions based on configuration.

Removes sessions that exceed TTL or exceed the maximum count. Returns the number of sessions pruned.

Trait Implementations

impl AuditPersistence for StateStore

fn save(&self, entries: &[TrailEntry]) -> Result<()>

Save entries to persistent storage.

fn load(&self) -> Result<Vec<TrailEntry>>

Load entries from persistent storage.

impl Clone for StateStore

fn clone(&self) -> StateStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StateStore

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

Formats the value using the given formatter.

impl MemoryStorage for StateStore

fn save_json_value<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, c: &'life1 str, k: &'life2 str, v: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save a JSON value to a category/key.

fn load_json_value<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, c: &'life1 str, k: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

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

Load a JSON value from a category/key.

fn list_category<'life0, 'life1, 'async_trait>( &'life0 self, category: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

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

List all keys in a category.

fn delete_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, category: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Delete a file by category/key. Returns true if the file existed.