Struct RuntimeOpsLifecycleRegistry 

pub struct RuntimeOpsLifecycleRegistry { /* private fields */ }

Per-runtime shared registry for async operation lifecycle truth.

All canonical lifecycle state mutations are delegated to [OpsLifecycleAuthority]. This shell manages I/O concerns: watcher channels, timestamps, peer handles, and snapshot assembly.

Implementations

impl RuntimeOpsLifecycleRegistry

pub fn new() -> Self

pub fn with_config(config: OpsLifecycleConfig) -> Self

pub fn set_persistence_channel( &self, tx: Sender<PersistedOpsSnapshot>, 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 set_detached_wake(&self, wake: Arc<DetachedWakeState>)

Wire the detached-wake state so that execute_effects arms pending and fires the Notify when a BackgroundToolOp reaches terminal.

pub fn from_recovered(snapshot: PersistedOpsSnapshot) -> Self

Recover from a persisted snapshot.

Rebuilds the authority (stripping non-terminal ops), 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.