Struct NativeLinuxOciBundleProvider 

pub struct NativeLinuxOciBundleProvider { /* private fields */ }

Prepares immutable bundles from Box image/rootfs policy while the separate A3S OCI Runtime service owns container lifecycle and I/O.

Implementations

impl NativeLinuxOciBundleProvider

pub fn new( home_dir: impl Into<PathBuf>, runtime_path: impl Into<PathBuf>, agent_path: impl Into<PathBuf>, ) -> Self

pub fn runtime_path(&self) -> &Path

pub fn agent_path(&self) -> &Path

pub fn with_pull_progress_fn(self, pull_progress_fn: PullProgressFn) -> Self

Trait Implementations

impl Clone for NativeLinuxOciBundleProvider

fn clone(&self) -> NativeLinuxOciBundleProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OciBundleProvider for NativeLinuxOciBundleProvider

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

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

Prepare one immutable OCI bundle after runtime capability preflight.

fn cleanup<'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,

Remove only Box-owned preparation artifacts after runtime cleanup.

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

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

Ensure the Box-owned init-output projection is ready before OCI start. Test and embedding providers may retain raw runtime output only.

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

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

Wait until the exact init stdout/stderr streams have reached EOF and Box’s configured log driver has consumed them.

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

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

Wait until the exact projection worker has stopped after the runtime owner was lost. This path must not claim that output was fully drained: owner-death recovery deliberately preserves an unknown exit status and may also have lost the tail of the init output stream.

fn preflight( &self, _record: &BoxRecord, _context: &OciBundlePreparationContext, ) -> ExecutionManagerResult<()>

Reject a runtime/provider mismatch before product or runtime mutation.