Struct Runtime 

pub struct Runtime<E> { /* private fields */ }

Implementations

impl<E> Runtime<E>

where E: LocalExecutor,

pub fn execute_workflow( &self, request: WorkflowExecutionRequest, ) -> WorkflowExecutionOutcome

impl<E> Runtime<E>

pub fn new(registry: CapabilityRegistry, executor: E) -> Self

pub fn with_workflow_registry(self, workflow_registry: WorkflowRegistry) -> Self

pub fn with_workspace_applications( self, applications: Vec<WorkspaceApplicationRegistration>, ) -> Self

pub fn from_workspace_app_state( workspace_root: &Path, workspace_id: &str, executor: E, validator_version: &str, ) -> Result<Self, WorkspaceAppStateFailure>

Loads a runtime from durable local workspace app registration state.

Errors

Returns WorkspaceAppStateFailure when the workspace has no app registration state, state is malformed or incompatible, or registry reconstruction fails validation.

pub fn with_observability_config( self, observability: RuntimeObservabilityConfig, ) -> Self

pub fn observability_config(&self) -> &RuntimeObservabilityConfig

pub fn with_security_config(self, security: RuntimeSecurityConfig) -> Self

pub fn with_event_sink(self, event_sink: Arc<dyn RuntimeEventSink>) -> Self

Configures delivery for runtime-owned lifecycle envelopes.

pub fn with_event_broker(self, event_broker: Arc<dyn EventBroker>) -> Self

Injects the EventBroker used by PlacementRouter Step 5.

pub fn with_trace_store(self, trace_store: Arc<Mutex<TraceStore>>) -> Self

Injects the TraceStore written by PlacementRouter Step 4.

pub fn event_broker(&self) -> Arc<dyn EventBroker>

Returns the runtime-owned event broker used for capability event publishing.

pub fn trace_store(&self) -> Arc<Mutex<TraceStore>>

Returns the runtime-owned placement-router trace store.

pub fn security_config(&self) -> &RuntimeSecurityConfig

pub fn capability_registry(&self) -> &CapabilityRegistry

Returns a reference to the capability registry.

pub fn register_capability( &mut self, registration: CapabilityRegistration, ) -> Result<RegistrationOutcome, RegistryFailure>

Registers a capability into the runtime’s registry.

Returns true when the capability was newly registered, false when the same contract digest was already present (idempotent no-op).

Errors

Returns RegistryFailure when contract validation fails or when a different contract digest conflicts with an existing immutable version.

pub fn workflow_registry(&self) -> &WorkflowRegistry

Returns a reference to the workflow registry.

pub fn workspace_applications(&self) -> &[WorkspaceApplicationRegistration]

Returns workspace application registrations loaded into this runtime.

pub fn workflow_registry_mut(&mut self) -> &mut WorkflowRegistry

Returns a mutable reference to the workflow registry.

pub fn register_workflow( &mut self, registration: WorkflowRegistration, ) -> Result<WorkflowRegistrationOutcome, WorkflowFailure>

Registers a workflow into the runtime’s workflow registry.

Errors

Returns WorkflowFailure when the workflow is invalid, references a missing capability, contains a cycle, or violates immutability.

pub fn execute_governed_model_dependency( &self, app_id: &str, app_version: &str, request: &GovernedModelExecutionRequest, ) -> Result<GovernedModelExecutionOutcome, GovernedModelExecutionError>

Executes an app-declared model dependency through the governed inference surface.

Errors

Returns inference::GovernedModelExecutionError when the app or interface is not registered, model resolution fails, or provider execution fails.

impl<E> Runtime<E>

where E: LocalExecutor,

pub fn execute(&self, request: RuntimeRequest) -> RuntimeExecutionOutcome

Executes one runtime request against the current registry state.

Trait Implementations

impl<E: Clone> Clone for Runtime<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for Runtime<E>

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

Formats the value using the given formatter.