Struct FileStateStore 

pub struct FileStateStore { /* private fields */ }

Append-only JSONL state store. Each entry is written to a file named after its id under the configured directory.

Concurrency: per-id writes are serialized via a parking_lot::Mutex over the id. Different ids can write in parallel.

Implementations

impl FileStateStore

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

Create a new store rooted at dir. The directory is created lazily on the first write.

pub fn in_sessions_dir(home: impl AsRef<Path>) -> Self

Build a store under <home>/sessions where home is $OXICODE_HOME or $HOME/.oxicode.

impl FileStateStore

pub async fn _append_with_id( &self, id: &PortId, entry: PortValue, ) -> Result<(), SdkError>

Append with a caller-chosen id (useful for migrating from existing storage). Idempotent: if the file already exists, the call errors.

Trait Implementations

impl Debug for FileStateStore

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

Formats the value using the given formatter.

impl StateStore for FileStateStore

fn append( &self, entry: PortValue, ) -> Pin<Box<dyn Future<Output = Result<PortId, SdkError>> + Send + '_>>

Persist an entry. Returns the assigned identifier.

fn load( &self, id: &PortId, ) -> Pin<Box<dyn Future<Output = Result<Option<PortValue>, SdkError>> + Send + '_>>

Load an entry by id.

fn list( &self, prefix: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<PortId>, SdkError>> + Send + '_>>

List all entry ids matching the given prefix (e.g. "session:").

fn delete( &self, id: &PortId, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + '_>>

Delete an entry by id.

fn load_all( &self, _prefix: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(PortId, PortValue)>, SdkError>> + Send + '_>>

Optional bulk-load of entries for a prefix. Default: None (impl may not support efficient bulk reads).