Struct BoxStateStore 

pub struct BoxStateStore { /* private fields */ }

Durable collection of local box execution records.

All mutating operations use the sibling boxes.json.lock advisory lock and a durable temporary-file rename. Callers must keep transaction closures synchronous and must not acquire the same store lock recursively.

Implementations

impl BoxStateStore

pub fn from_records(path: impl Into<PathBuf>, records: Vec<BoxRecord>) -> Self

Build an in-memory store for path from existing records.

pub fn load(path: &Path) -> Result<Self>

Load state strictly, returning invalid JSON or schema data as an error.

A missing state file is represented by an empty store and its parent directory is created for subsequent writes.

pub fn load_or_quarantine(path: &Path) -> Result<Self>

Load state and preserve an invalid file as a timestamped sibling.

This compatibility path keeps the CLI available for manual recovery. New runtime services should prefer Self::load and fail closed.

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

Load a side-effect-free snapshot.

This never creates directories, quarantines invalid data, acquires a lock, reconciles process state, or writes the file back.

pub fn save(&self) -> Result<()>

Save this snapshot under the cross-process state lock.

pub fn modify<R>( path: &Path, f: impl FnOnce(&mut Self) -> Result<R>, ) -> Result<R>

Apply a strict atomic read-modify-write transaction.

The closure runs while the cross-process lock is held. If it returns an error, no write is performed.

pub fn transact<R, E>( path: &Path, f: impl FnOnce(&mut Self) -> Result<R, E>, ) -> Result<R, E>

where E: From<Error>,

Apply a strict atomic transaction with a caller-defined error type.

This is equivalent to Self::modify but lets a domain repository return typed conflicts while still converting state I/O errors.

pub fn modify_or_quarantine<R, E>( path: &Path, f: impl FnOnce(&mut Self) -> Result<R, E>, ) -> Result<R, E>

where E: From<Error>,

Apply an atomic read-modify-write transaction that quarantines invalid existing state before starting from an empty collection.

This exists for CLI behavior compatibility. Runtime services should use Self::modify so corrupt durable state fails closed.

pub fn path(&self) -> &Path

Path of the durable state file.

pub fn records(&self) -> &[BoxRecord]

All execution records in persistence order.

pub fn records_mut(&mut self) -> &mut Vec<BoxRecord>

Mutable execution records for a synchronous transaction.

pub fn find_by_id(&self, id: &str) -> Option<&BoxRecord>

Find a record by exact execution ID.

pub fn find_by_id_mut(&mut self, id: &str) -> Option<&mut BoxRecord>

Find a mutable record by exact execution ID.

pub fn remove_by_id(&mut self, id: &str) -> bool

Remove a record by exact execution ID.

pub fn find_by_name(&self, name: &str) -> Option<&BoxRecord>

Find a record by exact user-visible name.

pub fn find_by_operation_id( &self, operation_id: &OperationId, ) -> Option<&BoxRecord>

Find a managed execution by its idempotent creation operation.

pub fn find_by_operation_id_mut( &mut self, operation_id: &OperationId, ) -> Option<&mut BoxRecord>

Find a mutable managed execution by its idempotent creation operation.

pub fn find_by_id_prefix(&self, prefix: &str) -> Vec<&BoxRecord>

Find records matching a full-ID or short-ID prefix.

pub fn list(&self, all: bool) -> Vec<&BoxRecord>

List all records or only records in the running state.

Trait Implementations

impl Debug for BoxStateStore

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

Formats the value using the given formatter.