Struct ContainerdStep 

pub struct ContainerdStep { /* private fields */ }

Containerdstep.

Implementations

impl ContainerdStep

pub fn new(config: ContainerdConfig) -> Self

pub async fn run_service( addr: &str, container_id: &str, image: &str, env: &HashMap<String, String>, ) -> Result<(), WfeError>

Start a long-running service container via the containerd gRPC API.

Used by ContainerdServiceProvider to provision infrastructure services. The container runs on the host network so its ports are accessible on 127.0.0.1. Unlike step execution, this does NOT wait for the container to exit.

pub async fn cleanup_service( addr: &str, container_id: &str, ) -> Result<(), WfeError>

Stop and clean up a service container via the containerd gRPC API.

pub fn parse_outputs(stdout: &str) -> HashMap<String, String>

Parse ##wfe[output key=value] lines from stdout.

pub fn build_output_data( step_name: &str, stdout: &str, stderr: &str, exit_code: i32, parsed_outputs: &HashMap<String, String>, ) -> Value

Build the output data JSON value from step execution results.

Trait Implementations

impl StepBody for ContainerdStep

fn mount_artifacts<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, context: &'life1 StepExecutionContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Mount any artifacts this step requires.

fn unmount_artifacts<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _context: &'life1 StepExecutionContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Unmount and clean up artifacts.

fn run<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, context: &'life1 StepExecutionContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<ExecutionResult>> + Send + 'async_trait>>

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

Execute the step.