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

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 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.