Struct DependencyWaiter 

pub struct DependencyWaiter { /* private fields */ }

Orchestrates waiting for dependencies with configurable timeout and actions

Polls the condition checker at regular intervals until the condition is satisfied or the timeout is reached.

Implementations

impl DependencyWaiter

pub fn new(condition_checker: DependencyConditionChecker) -> Self

Create a new dependency waiter with default poll interval (1 second)

pub fn with_poll_interval(self, interval: Duration) -> Self

Set the polling interval

pub fn poll_interval(&self) -> Duration

Get the polling interval

pub async fn wait_for_dependency(&self, dep: &DependsSpec) -> Result<WaitResult>

Wait for a single dependency to be satisfied

Arguments

• dep - The dependency specification to wait for

Returns

• WaitResult::Satisfied if the condition was met
• WaitResult::TimedOutContinue if timed out with on_timeout: continue
• WaitResult::TimedOutWarn if timed out with on_timeout: warn
• WaitResult::TimedOutFail if timed out with on_timeout: fail

Errors

Returns an error if the condition check itself encounters an unrecoverable error.

pub async fn wait_for_all( &self, deps: &[DependsSpec], ) -> Result<Vec<WaitResult>>

Wait for all dependencies to be satisfied

Waits for each dependency in order. Returns early on first failure (if on_timeout: fail).

Arguments

• deps - Slice of dependency specifications to wait for

Returns

Vector of wait results for each dependency

Errors

Returns an error if a condition check encounters an unrecoverable error.