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