Struct DockerBackend

pub struct DockerBackend { /* private fields */ }

Represents the Docker backend.

Implementations

impl DockerBackend

pub async fn new( config: Arc<Config>, backend_config: &DockerBackendConfig, ) -> Result<Self>

Constructs a new Docker task execution backend with the given configuration.

The provided configuration is expected to have already been validated.

Trait Implementations

impl TaskExecutionBackend for DockerBackend

fn max_concurrency(&self) -> u64

Gets the maximum concurrent tasks supported by the backend.

fn constraints( &self, requirements: &HashMap<String, Value>, _: &HashMap<String, Value>, ) -> Result<TaskExecutionConstraints>

Gets the execution constraints given a task’s requirements and hints.

fn guest_work_dir(&self) -> Option<&Path>

Gets the guest path the task working directory (e.g. /mnt/work).

fn localize_inputs<'a, 'b, 'c, 'd>( &'a self, downloader: &'b HttpDownloader, inputs: &'c mut [Input], ) -> BoxFuture<'d, Result<()>>

where Self: 'd, 'a: 'd, 'b: 'd, 'c: 'd,

Localizes the given set of inputs for the backend.

fn spawn( &self, request: TaskSpawnRequest, token: CancellationToken, ) -> Result<TaskExecutionEvents>

Spawns a task with the execution backend.

fn cleanup<'a, 'b, 'c>( &'a self, output_dir: &'b Path, token: CancellationToken, ) -> Option<BoxFuture<'c, ()>>

where Self: 'c, 'a: 'c, 'b: 'c,

Performs cleanup operations after top-level workflow or task evaluation completes.