Struct OciProcesses 

pub struct OciProcesses { /* private fields */ }

Implementations

impl OciProcesses

pub fn new(host: HostId) -> Self

Trait Implementations

impl Debug for OciProcesses

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

Formats the value using the given formatter.

impl ExecutionProvider for OciProcesses

fn probe(&self, policy: &ScalePolicy) -> ProviderCapability

fn resolve( &self, policy: &ScalePolicy, ) -> Result<Option<ResolvedEnvironment>, FailureReason>

Resolve Auto and image identity before allocation or GitHub JIT. Native has no image.

fn prepare( &self, attempt: &RunnerAttempt, policy: &ScalePolicy, ) -> Result<PreparedEnvironment, FailureReason>

fn start( &self, prepared: PreparedEnvironment, attempt: &RunnerAttempt, handoff: OneTimeJitHandoff<'_>, ) -> Result<EnvironmentIdentity, ProcessStartFailure>

fn inspect( &self, attempt: &RunnerAttempt, ) -> Result<EnvironmentState, FailureReason>

fn recover( &self, attempt: &RunnerAttempt, ) -> Result<EnvironmentState, FailureReason>

fn stop(&self, attempt: &RunnerAttempt) -> Result<ProviderStop, FailureReason>

fn destroy( &self, attempt: &RunnerAttempt, ) -> Result<ProviderDestroy, FailureReason>

fn owns(&self, attempt: &RunnerAttempt) -> Result<bool, FailureReason>

Independent resource metadata must match the journal before destructive calls.

fn enumerate_owned(&self, host: HostId) -> Vec<EnvironmentIdentity>

fn spawn( &self, attempt: &RunnerAttempt, config: &EncodedJitConfig, ) -> Result<u32, ProcessStartFailure>

fn is_alive(&self, attempt: &RunnerAttempt) -> Result<bool, FailureReason>

fn recovered_pid( &self, attempt: &RunnerAttempt, ) -> Result<Option<u32>, FailureReason>

Durable identity observed for a process that spawned before the starting journal write survived.

fn completed_successfully(&self, attempt: &RunnerAttempt) -> bool

True only for a child this invocation owned and reaped with a successful exit status. A recovered process that is merely gone answers false.

fn record_terminate_intent( &self, attempt: &RunnerAttempt, ) -> Result<(), FailureReason>

fn has_terminate_intent(&self, attempt: &RunnerAttempt) -> bool

fn terminate(&self, attempt: &RunnerAttempt) -> Result<(), FailureReason>

fn diagnostics(&self, _attempt: &RunnerAttempt) -> Vec<ProviderDiagnostic>