Struct DockerBackend 

pub struct DockerBackend { /* private fields */ }

The remote-Docker compute backend: a connected Engine API client.

Implementations

impl DockerBackend

pub fn connect() -> Result<Self, BackendError>

Connect to the Docker daemon configured by the environment (DOCKER_HOST + TLS/SSH vars, or the platform default socket).

pub fn with_client(docker: Docker) -> Self

Wrap an already-connected client (for tests / custom transports).

pub fn with_endpoint(self, endpoint: DockerEndpoint) -> Self

Select how a launched workload’s endpoint is reported (see DockerEndpoint).

pub fn with_writable_root_allowed(self, allowed: bool) -> Self

Allow a spec’s writable_root to relax the read-only root here (single-tenant posture). Off by default, so the multi-tenant guard keeps the hardened root.

pub fn with_cap_add_allowed(self, allowed: bool) -> Self

Allow a spec’s cap_add to add capabilities back on top of the dropped-ALL default here (single-tenant posture). Off by default, so the multi-tenant guard keeps every capability dropped.

pub fn with_volume_mode(self, mode: DockerVolumeMode) -> Self

Select how persistent volumes are backed (see DockerVolumeMode).

pub fn with_data_dir(self, data_dir: impl Into<PathBuf>) -> Self

Set the node data directory used for Bind-mode volume host paths.

pub async fn reachable(&self) -> bool

Whether the daemon answers a ping — used to decide whether to register this backend (a connected client doesn’t imply a reachable daemon).

Trait Implementations

impl ComputeBackend for DockerBackend

fn id(&self) -> &'static str

Stable backend id ("vmm" / "container" / "cloudflare" / "docker").

fn capabilities(&self) -> Capabilities

What this backend can do here (used by the scheduler + policy gate).

fn materialize<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 ComputeSpec, ) -> Pin<Box<dyn Future<Output = Result<Artifact, BackendError>> + Send + 'async_trait>>

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

Stage spec’s artifact into whatever this backend boots from. Idempotent + content-addressed (cache/dedup by spec id).

fn launch<'life0, 'life1, 'async_trait>( &'life0 self, req: &'life1 LaunchRequest, ) -> Pin<Box<dyn Future<Output = Result<Instance, BackendError>> + Send + 'async_trait>>

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

Launch one replica; returns its handle + routable endpoint.

fn stop<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 InstanceHandle, ) -> Pin<Box<dyn Future<Output = Result<(), BackendError>> + Send + 'async_trait>>

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

Stop + clean up a replica (idempotent; safe on a half-launched instance).

fn health<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 InstanceHandle, ) -> Pin<Box<dyn Future<Output = Result<Health, BackendError>> + Send + 'async_trait>>

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

Liveness/readiness of a running replica.

fn snapshot<'life0, 'life1, 'async_trait>( &'life0 self, _handle: &'life1 InstanceHandle, ) -> Pin<Box<dyn Future<Output = Result<Option<Snapshot>, BackendError>> + Send + 'async_trait>>

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

Snapshot a replica for scale-to-zero (backends that support it).

fn restore<'life0, 'life1, 'async_trait>( &'life0 self, _snapshot: &'life1 Snapshot, ) -> Pin<Box<dyn Future<Output = Result<Instance, BackendError>> + Send + 'async_trait>>

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

Restore a snapshotted replica.