Struct ManagedExecutionStore 

pub struct ManagedExecutionStore { /* private fields */ }

Strict durable repository used by the local ExecutionManager.

Implementations

impl ManagedExecutionStore

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

pub fn path(&self) -> &Path

pub fn get( &self, execution_id: &ExecutionId, ) -> ManagedExecutionStoreResult<Option<BoxRecord>>

Return one managed record without mutating or reconciling state.

pub fn list(&self) -> ManagedExecutionStoreResult<Vec<BoxRecord>>

Return every managed record without reconciling provider state.

Legacy CLI records share the same state file and are deliberately excluded. Loading remains strict: one malformed managed record fails the complete snapshot instead of letting provider discovery skip corrupt ownership metadata.

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

Return the record reserved by an idempotent creation operation.

pub fn reserve( &self, record: BoxRecord, ) -> ManagedExecutionStoreResult<ManagedExecutionReservation>

Atomically reserve one creation operation before backend side effects.

Retrying the same operation with the same full request returns the existing record. Reusing an operation ID for different creation intent fails without changing durable state.

pub fn begin_remove( &self, execution_id: &ExecutionId, expected_generation: ExecutionGeneration, ) -> ManagedExecutionStoreResult<Option<BoxRecord>>

Claim terminal-record removal before deleting host resources.

The durable removing state prevents another lifecycle operation from reviving the execution while cleanup is in progress. A retry observes the same claim and can resume cleanup after a process crash.

pub fn finish_remove( &self, execution_id: &ExecutionId, expected_generation: ExecutionGeneration, ) -> ManagedExecutionStoreResult<bool>

Forget a generation only after its durable removal claim has completed.

pub fn transition( &self, execution_id: &ExecutionId, expected_generation: ExecutionGeneration, expected_state: ManagedExecutionState, next_state: ManagedExecutionState, ) -> ManagedExecutionStoreResult<BoxRecord>

Atomically compare generation and state, then persist one legal edge.

Completing pause and resume, and advancing a restart from teardown to startup, increments the runtime generation exactly once. Other edges retain the current generation.

pub fn transition_with( &self, execution_id: &ExecutionId, expected_generation: ExecutionGeneration, expected_state: ManagedExecutionState, next_state: ManagedExecutionState, update: impl FnOnce(&mut BoxRecord), ) -> ManagedExecutionStoreResult<BoxRecord>

Persist one legal transition and update runtime evidence in the same transaction.

Trait Implementations

impl Clone for ManagedExecutionStore

fn clone(&self) -> ManagedExecutionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ManagedExecutionStore

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

Formats the value using the given formatter.