Struct FileTransactionStore 

pub struct FileTransactionStore { /* private fields */ }

Durable cross-process transaction state using only the Rust standard library.

Each operation takes a short process-local mutex and an OS file lock, refreshes only unseen append-log bytes, validates checksums and lifecycle edges, then synchronizes at most one complete record. At the configured byte ceiling it compacts into the inactive log and switches a fixed-size, double-buffered control record. Monty execution, VFS work, and host commit operations never run while either lock is held.

Implementations

impl FileTransactionStore

pub fn open( data_directory: impl AsRef<Path>, config: FileStoreConfig, ) -> Result<Self, TransactionStoreError>

Open or initialize a durable transaction store below data_directory.

Errors

Returns an error for filesystem/lock failures, invalid bounds, corruption, an invalid persisted state edge, or a configured size ceiling.

pub fn open_in( data_directory: &DataDirectory, config: FileStoreConfig, ) -> Result<Self, TransactionStoreError>

Open or initialize a durable transaction store below a pinned capability.

Errors

Returns an error for invalid bounds, filesystem/lock failures, corruption, an invalid persisted state edge, or a configured size ceiling.

pub fn active_log_path(&self) -> Result<PathBuf, TransactionStoreError>

Return the currently active state-log path for diagnostics and backup tooling.

Errors

Returns an error if the cross-process lock or compact-log control journal cannot be read safely.

Trait Implementations

impl Clone for FileTransactionStore

fn clone(&self) -> FileTransactionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileTransactionStore

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

Formats the value using the given formatter.

impl TransactionStore for FileTransactionStore

fn create(&self, record: TransactionRecord) -> Result<(), TransactionStoreError>

Insert one record whose state was reached through validated in-memory edges.

fn get( &self, id: TransactionId, ) -> Result<TransactionRecord, TransactionStoreError>

Load one immutable record snapshot.

fn compare_and_transition( &self, id: TransactionId, expected: TransactionState, next: TransactionState, ) -> Result<TransactionRecord, TransactionStoreError>

Compare exact state and perform one valid transition atomically.

fn approve( &self, id: TransactionId, grant: ApprovalGrant, ) -> Result<TransactionRecord, TransactionStoreError>

Bind an independent grant and move PendingApproval to Approved atomically.

fn reserve( &self, id: TransactionId, now_unix_ms: u64, ) -> Result<CommitReservation, TransactionStoreError>

Atomically consume AutoApproved or unexpired Approved into Reserved.