Struct OciLocalExecutionBackend 

pub struct OciLocalExecutionBackend { /* private fields */ }

Opt-in canonical local-execution backend over one A3S OCI host service.

Implementations

impl OciLocalExecutionBackend

pub fn from_client( endpoint: OciRuntimeEndpoint, client: RuntimeClient, provider: Arc<dyn OciBundleProvider>, ) -> ExecutionManagerResult<Self>

Construct from an already connected public SDK client.

pub async fn connect( endpoint: OciRuntimeEndpoint, provider: Arc<dyn OciBundleProvider>, ) -> ExecutionManagerResult<Self>

Connect to a local host service and retain only its public SDK boundary.

Trait Implementations

impl Clone for OciLocalExecutionBackend

fn clone(&self) -> OciLocalExecutionBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LocalExecutionBackend for OciLocalExecutionBackend

fn route_for_create( &self, _record: &BoxRecord, ) -> ExecutionManagerResult<ManagedRuntimeRoute>

Select the durable route for a new record before capability preflight.

fn preflight<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reject an unsupported execution before its durable reservation is published. Backends must repeat mutable capability checks at launch.

fn start<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<LocalExecutionHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn inspect<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<LocalExecutionObservation>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pause<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, keep_memory: bool, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<LocalExecutionHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn resume<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<LocalExecutionHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn preflight_resource_update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, update: &'life2 ExecutionResourceUpdate, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Validate a complete live resource contract before a durable mutation claim.

fn update_resources<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, operation_id: &'life2 BoxOperationId, update: &'life3 ExecutionResourceUpdate, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Apply the exact persisted resource update operation.

fn list_processes<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionProcessInventory>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return live init and exec processes for the record’s exact runtime target.

fn stats<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return normalized counters for the record’s exact runtime target.

fn events<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: ExecutionEventsRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionEventBatch>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Poll ordered events for the record’s exact runtime target.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: BoxExecRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute one captured process through a backend-owned, generation-fenced session boundary. The legacy VM backend retains its socket transport; SDK-backed implementations override this method.

fn start_process<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: BoxExecRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionProcess>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start one streaming non-terminal process through the backend boundary.

fn start_pty<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: PtyRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionProcess>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start one interactive terminal process through the backend boundary.

fn transfer_file<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: BoxFileRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<BoxFileResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Transfer one file through the backend’s exact-generation session.

fn filesystem<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, request: BoxFilesystemRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<BoxFilesystemResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Inspect or mutate the exact generation’s workload filesystem.

fn kill<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<KillOutcome>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn kill_with_status<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<LocalExecutionTermination>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Kill the current execution and return its exact terminal status when the backend provides one. Implementations that cannot observe status retain the legacy kill behavior through this default.

fn prepare_quiescent_rootfs<'life0, 'life1, 'async_trait>( &'life0 self, _record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Make a stopped, storage-retained rootfs available for a filesystem snapshot without starting the execution runtime.

fn cleanup_quiescent_rootfs<'life0, 'life1, 'async_trait>( &'life0 self, _record: &'life1 BoxRecord, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Release any transient rootfs mount created by Self::prepare_quiescent_rootfs while retaining guest data.

fn stop_for_restart<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 BoxRecord, _timeout_secs: Option<u64>, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<KillOutcome>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop the current runtime while preserving execution-owned storage for the replacement generation.