Struct JobRunner 

pub struct JobRunner { /* private fields */ }

Runs a specific Job. The simplest way to use this is to repeatedly call run_next_step() until next_step_index() >= step_count().

Implementations

impl JobRunner

pub fn container_images(&self) -> &[ContainerImage]

The job requires a specific set of containers, one container per entry in the returned list. Each container must use the given ContainerImage.

pub fn step_count(&self) -> StepIndex

The total number of steps in the job.

pub fn next_step_index(&self) -> StepIndex

The index of the next step to be executed.

pub fn next_step_name(&self) -> Result<Option<String>, RunnerError>

The name of the next step to be executed, if there is one.

pub fn job_name(&self) -> &str

The job name.

pub fn find_step_by_name( &self, step_name: &str, ) -> Result<Option<StepIndex>, RunnerError>

Look up a step by name. We don’t have access to variables set by previous steps so this might not work in obscure cases…

pub fn peek_step_env( &self, step_index: StepIndex, ) -> Result<LinkedHashMap<String, String>, RunnerError>

Get the environment variables set in a specific step. We don’t have access to variables set by previous steps so this might not work in obscure cases…

pub async fn run_next_step<B: RunnerBackend, I>( &mut self, interpose: I, backend: &mut B, ) -> Result<i32, RunnerError>

where I: FnOnce(&mut Vec<String>),

interpose lets you modify the command that will be run for the step.