Struct RunnerRouter 

pub struct RunnerRouter { /* private fields */ }

Router that selects an appropriate Runner for a given TaskSpec.

Runners are checked in the order they were registered. The first runner whose Runner::supports method returns true and satisfies the TaskSpec::runner_selector (if any) is used to build the task.

Notes

• TaskKind::Embedded is not routable — use SupervisorApi::submit_with_task instead.
• Default BuildContext uses empty env and NoOpMetrics.

Also

• Runner — trait that concrete executors implement.
• BuildContext — shared dependencies for all runners.
• RunnerError::NoRunner — returned when no runner matches.

Implementations

impl RunnerRouter

pub fn new() -> Self

Create an empty router with a default build context.

pub fn with_context(self, ctx: BuildContext) -> Self

Set a custom build context for all runners managed by this router.

This is typically used to inject shared dependencies (config, observability, global handles, etc.) into runner instances.

pub fn register(&mut self, runner: Arc<dyn Runner>)

Register a new runner without labels.

Runners are queried in the order they are registered; the first one that reports supports(spec) == true (and matches labels, if any) is used.

pub fn register_with_labels(&mut self, runner: Arc<dyn Runner>, labels: Labels)

Register a new runner with static labels.

These labels are used by the router to further narrow down candidates when TaskSpec::runner_selector is set.

pub fn pick(&self, spec: &TaskSpec) -> Option<&Arc<dyn Runner>>

Pick the first runner that claims to support the given spec and matches the runner selector.

Routing rules:

• filter runners by Runner::supports(spec);
• if spec.runner_selector() is set, keep only runners whose labels satisfy all match_labels and match_expressions requirements;
• pick the first matching entry.

pub fn build(&self, spec: &TaskSpec) -> Result<TaskRef, RunnerError>

Build a TaskRef for the given spec using the selected runner.

TaskKind::Embedded is not routable and must be used with SupervisorApi::submit_with_task.

pub fn contains_label(&self, label_key: &str, label_value: &str) -> bool

Returns true if at least one registered runner has label_key == label_value.

Trait Implementations

impl Default for RunnerRouter

fn default() -> RunnerRouter

Returns the “default value” for a type.