Skip to main content

Module orchestrator

Module orchestrator 

Source
Expand description

Orchestrator + builder + execution errors. Orchestrator — drives a Plan to completion.

Orchestrator owns the actions, the cache, and the execution context; execute_plan walks the plan layer by layer, fanning the stale actions out into a FuturesUnordered capped by a tokio::sync::Semaphore. On the first error in ExecMode::FailFast mode, a shared CancellationToken is fired so in-flight peers can short-circuit. ExecMode::KeepGoing lets the current layer settle but still halts before the next layer is started.

Implementation invariant: this module never uses futures::future::join_all — it would defeat FailFast because join_all ignores cancellation and waits for every future to finish.

Structs§

Builder
Builder for Orchestrator. Use Orchestrator::builder to obtain one.
Orchestrator
Top-level orchestrator. Construct via Orchestrator::builder.

Enums§

BuilderError
Errors raised while validating a Builder configuration.
ExecError
Errors raised while executing a Plan.