Struct LocalExecutionManager 

pub struct LocalExecutionManager { /* private fields */ }

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

Implementations

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

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