Struct LocalExecutionManager 

pub struct LocalExecutionManager { /* private fields */ }

Local lifecycle facade shared by service, CLI, and SDK adapters.

Implementations

impl LocalExecutionManager

pub async fn with_native_linux_oci_migration( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, config: NativeLinuxOciMigrationConfig, ) -> ExecutionManagerResult<Self>

Compose the retained VM backend with the production native-Linux OCI owner and bundle provider. Only new Sandbox reservations use OCI.

pub async fn with_windows_whpx_oci_qualification( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, config: WindowsWhpxOciMigrationConfig, ) -> ExecutionManagerResult<Self>

Compose the retained backend with the externally launched Box/WHPX OCI service.

pub async fn with_configured_backend( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, ) -> ExecutionManagerResult<Self>

Select the production migration composition only when explicitly opted in through A3S_BOX_OCI_MIGRATION=sandbox.

pub async fn with_configured_backend_and_pull_progress( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, pull_progress_fn: Option<PullProgressFn>, ) -> ExecutionManagerResult<Self>

Configured construction retaining the CLI’s image-pull progress hook on both the legacy and migrated preparation paths.

impl LocalExecutionManager

pub async fn remove_execution( &self, execution_id: &ExecutionId, expected_generation: ExecutionGeneration, ) -> ExecutionManagerResult<bool>

Remove one terminal generation after durably claiming its teardown.

A failed cleanup deliberately leaves the record in removing. Retrying the same generation resumes cleanup before the record is forgotten.

impl LocalExecutionManager

pub fn new( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, backend: Arc<dyn LocalExecutionBackend>, ) -> Self

pub fn state_path(&self) -> &Path

pub async fn preflight_isolation( &self, isolation: ExecutionIsolation, ) -> ExecutionManagerResult<()>

Probe the backend selected by the current creation policy before an image pull or other product preparation. Record creation repeats all mutable capability checks before publishing durable state.

pub fn with_vm_backend( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, ) -> Self

pub fn with_oci_migration_backend( state_path: impl Into<PathBuf>, home_dir: impl Into<PathBuf>, oci_backend: Arc<dyn LocalExecutionBackend>, policy: OciMigrationPolicy, ) -> Self

Compose the retained Box backend with an explicitly supplied OCI SDK backend. The policy affects new reservations only; every selected route is persisted before preflight and remains authoritative after restart.

Trait Implementations

impl Clone for LocalExecutionManager

fn clone(&self) -> LocalExecutionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ExecutionManager for LocalExecutionManager

fn create<'life0, 'life1, 'async_trait>( &'life0 self, request: CreateExecutionRequest, operation_id: &'life1 OperationId, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionReservation>> + Send + 'async_trait>>

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

Persist exactly one unstarted execution reservation for operation_id.

fn start<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionLease>> + Send + 'async_trait>>

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

Start one created execution after fencing stale callers by generation.

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

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

fn read_logs<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<Vec<LogEntry>>> + Send + 'async_trait>>

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

Read structured stdout/stderr entries after fencing the runtime generation.

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

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

Return the runtime-visible init and live exec processes for one exact generation.

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

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

Return one normalized resource snapshot for an exact generation.

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

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

Poll ordered runtime events without crossing the selected generation.

fn update_resources<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, operation_id: &'life2 OperationId, update: ExecutionResourceUpdate, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionLease>> + Send + 'async_trait>>

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

Apply a replay-safe partial live resource update to one exact generation.

fn create_filesystem_snapshot<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, snapshot_id: &'life2 ExecutionSnapshotId, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionSnapshot>> + Send + 'async_trait>>

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

Temporarily quiesce the execution, atomically capture its rootfs in the runtime-managed snapshot store, and restore its prior stable state.

fn filesystem_snapshot_size<'life0, 'life1, 'async_trait>( &'life0 self, snapshot_id: &'life1 ExecutionSnapshotId, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<Option<u64>>> + Send + 'async_trait>>

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

Return the size of a fully published runtime-managed snapshot, or None when it does not exist.

fn delete_filesystem_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, snapshot_id: &'life1 ExecutionSnapshotId, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<bool>> + Send + 'async_trait>>

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

Delete a runtime-managed snapshot, refusing while an active execution still uses it as a copy-on-write lower.

fn pause<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, keep_memory: bool, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionLease>> + Send + 'async_trait>>

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

Pause one execution and return the generation-fenced paused lease.

fn resume<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionLease>> + Send + 'async_trait>>

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

fn restart_with_options<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, operation_id: &'life2 OperationId, options: RestartExecutionOptions, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionLease>> + Send + 'async_trait>>

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

Restart with controls that become part of the durable operation intent.

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

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

fn kill_with_options<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, options: KillExecutionOptions, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<KillOutcome>> + Send + 'async_trait>>

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

Terminate one execution with controls that survive lifecycle recovery.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, expected_generation: ExecutionGeneration, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<bool>> + Send + 'async_trait>>

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

Remove one terminal execution and all runtime-owned resources.

fn reconcile<'life0, 'life1, 'async_trait>( &'life0 self, operation_id: &'life1 OperationId, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ReconcileOutcome>> + Send + 'async_trait>>

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

fn create_and_start<'life0, 'life1, 'async_trait>( &'life0 self, request: CreateExecutionRequest, operation_id: &'life1 OperationId, ) -> Pin<Box<dyn Future<Output = Result<ExecutionLease, ExecutionManagerError>> + Send + 'async_trait>>

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

Create and start exactly one execution for operation_id.

fn restart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, operation_id: &'life2 OperationId, ) -> Pin<Box<dyn Future<Output = Result<ExecutionLease, ExecutionManagerError>> + Send + 'async_trait>>

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

Terminate the current runtime, advance its generation exactly once, and start it again under an idempotent operation identity.

impl ExecutionPortConnector for LocalExecutionManager

fn connect_port<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, port: NonZeroU16, timeout: Duration, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionPortStream>> + Send + 'async_trait>>

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

impl ExecutionSessionManager for LocalExecutionManager

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, request: ExecRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecOutput>> + Send + 'async_trait>>

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

fn start_process<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, request: ExecRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<ExecutionProcess>> + Send + 'async_trait>>

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

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

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

fn transfer_file<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, request: FileRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<FileResponse>> + Send + 'async_trait>>

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

fn filesystem<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, generation: ExecutionGeneration, request: FilesystemRequest, ) -> Pin<Box<dyn Future<Output = ExecutionManagerResult<FilesystemResponse>> + Send + 'async_trait>>

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