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, ) -> Result<Self, OpsLifecycleError>

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 only with completion entries accepted by generated recovery authority.

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

Capture a serializable snapshot of the current state for persistence.

Includes authority state, operation specs, completion entries, and generated completion-consumer cursor values.

pub fn completion_cursor_snapshot(&self) -> EpochCursorSnapshot

Snapshot generated completion-consumer cursor state.

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 register_operation_with_admission_limit( &self, spec: OperationSpec, max_concurrent: Option<usize>, ) -> Result<(), OpsLifecycleError>

Register an operation while applying a caller-supplied generated admission limit for this registration.

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, ) -> Result<Option<OperationLifecycleSnapshot>, OpsLifecycleError>

fn list_operations( &self, ) -> Result<Vec<OperationLifecycleSnapshot>, OpsLifecycleError>

fn classify_operation_terminality( &self, id: &OperationId, status: OperationStatus, ) -> Result<bool, OpsLifecycleError>

Classify operation terminality through the registry’s generated lifecycle authority.

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

Classify operation public result projection through generated lifecycle authority.

fn classify_operation_completion_wake( &self, id: &OperationId, kind: OperationKind, ) -> Result<OperationCompletionWakeClass, OpsLifecycleError>

Classify whether a completion-feed entry should wake the owning agent as a detached background job completion.

fn classify_operation_transition_idempotence( &self, id: &OperationId, action: OperationLifecycleAction, ) -> Result<bool, OpsLifecycleError>

Classify whether a generated invalid-transition rejection is an idempotent success for the requested lifecycle action.

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 completion_cursor( &self, consumer: CompletionCursorConsumer, ) -> Result<Option<CompletionSeq>, OpsLifecycleError>

Read the generated completion-consumer cursor for this registry.

fn advance_completion_cursor( &self, consumer: CompletionCursorConsumer, cursor: CompletionSeq, projection: Option<&EpochCursorState>, ) -> Result<CompletionSeq, OpsLifecycleError>

Advance a completion-consumer cursor through generated authority.

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.