Struct RuntimeOpsLifecycleRegistry 

pub struct RuntimeOpsLifecycleRegistry { /* private fields */ }

Per-runtime shared registry for async operation lifecycle truth.

Per-operation canonical lifecycle state is owned by the DSL authority embedded in the shell. This struct manages I/O concerns: watcher channels, timestamps, peer handles, snapshot assembly, FIFO eviction, and the completion feed buffer.

Implementations

impl RuntimeOpsLifecycleRegistry

pub fn new() -> Self

pub fn with_config(config: OpsLifecycleConfig) -> Self

pub fn set_persistence_channel( &self, tx: UnboundedSender<OpsLifecyclePersistenceRequest>, epoch_id: RuntimeEpochId, cursor_state: Arc<EpochCursorState>, )

Wire a persistence channel for durable snapshot writes.

After this call, terminal transitions (complete/fail/cancel/abort) capture a snapshot and queue it to the channel. A dedicated persistence task should drain the channel and write to the store.

pub fn from_recovered(snapshot: PersistedOpsSnapshot) -> Self

Recover from a persisted snapshot.

Rebuilds DSL state (stripping non-terminal ops — only terminals survive recovery), creates fresh shell records from specs, and seeds the feed buffer with persisted completion entries.

pub fn capture_persistence_snapshot( &self, epoch_id: RuntimeEpochId, cursor_state: &EpochCursorState, ) -> PersistedOpsSnapshot

Capture a serializable snapshot of the current state for persistence.

Includes authority state, operation specs, completion entries, and cursor values. Cursor values may be stale relative to the agent’s true position (monotonic staleness, not atomicity).

pub fn completion_feed_handle(&self) -> Arc<dyn CompletionFeed>

Return a read handle to the completion feed.

Trait Implementations

impl Debug for RuntimeOpsLifecycleRegistry

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

Formats the value using the given formatter.

impl Default for RuntimeOpsLifecycleRegistry

fn default() -> Self

Returns the “default value” for a type.

impl OpsLifecycleRegistry for RuntimeOpsLifecycleRegistry

fn register_operation( &self, spec: OperationSpec, ) -> Result<(), OpsLifecycleError>

fn provisioning_succeeded( &self, id: &OperationId, ) -> Result<(), OpsLifecycleError>

fn provisioning_failed( &self, id: &OperationId, error: String, ) -> Result<(), OpsLifecycleError>

fn peer_ready( &self, id: &OperationId, peer: OperationPeerHandle, ) -> Result<(), OpsLifecycleError>

fn register_watcher( &self, id: &OperationId, ) -> Result<OperationCompletionWatch, OpsLifecycleError>

fn report_progress( &self, id: &OperationId, _update: OperationProgressUpdate, ) -> Result<(), OpsLifecycleError>

fn complete_operation( &self, id: &OperationId, result: OperationResult, ) -> Result<(), OpsLifecycleError>

fn fail_operation( &self, id: &OperationId, error: String, ) -> Result<(), OpsLifecycleError>

fn abort_provisioning( &self, id: &OperationId, reason: Option<String>, ) -> Result<(), OpsLifecycleError>

fn cancel_operation( &self, id: &OperationId, reason: Option<String>, ) -> Result<(), OpsLifecycleError>

fn request_retire(&self, id: &OperationId) -> Result<(), OpsLifecycleError>

fn mark_retired(&self, id: &OperationId) -> Result<(), OpsLifecycleError>

fn snapshot(&self, id: &OperationId) -> Option<OperationLifecycleSnapshot>

fn list_operations(&self) -> Vec<OperationLifecycleSnapshot>

fn terminate_owner(&self, reason: String) -> Result<(), OpsLifecycleError>

fn collect_completed( &self, ) -> Result<Vec<(OperationId, OperationTerminalOutcome)>, OpsLifecycleError>

Drain all completed operations from the registry, returning their outcomes.

fn completion_feed(&self) -> Option<Arc<dyn CompletionFeed>>

Return the canonical completion feed, if this registry supports it.

fn wait_all( &self, _run_id: &RunId, ids: &[OperationId], ) -> Pin<Box<dyn Future<Output = Result<WaitAllResult, OpsLifecycleError>> + Send + '_>>

Register an authority-owned barrier wait and await its completion.