Struct WorkflowCtx 

pub struct WorkflowCtx { /* private fields */ }

Shared, cheaply-cloneable workflow run context.

Implementations

impl WorkflowCtx

pub fn builder(provider: Arc<BoxedProvider>) -> WorkflowCtxBuilder

Start building a context from a type-erased provider.

pub fn is_cancelled(&self) -> bool

Whether the run has been cancelled.

pub fn stop(&self)

Stop the run: fires the shared cancellation token so in-flight agents wind down at their next leaf cancel-check (and combinator tasks abort). Idempotent. Restarting a stopped run is done by re-running with a resume journal: completed agents replay, the stopped ones run live.

pub fn cancellation_token(&self) -> CancellationToken

A clone of the run’s cancellation token (for external pause/stop wiring).

pub fn spawned(&self) -> u64

Total agents issued so far (monotonic; includes rejected admissions).

pub fn max_agents(&self) -> u64

The configured runaway agent backstop.

pub fn budget(&self) -> &Budget

The shared token-equivalent budget pool.

pub fn remaining(&self) -> u64

Remaining budget headroom, or u64::MAX if unbounded. Drives loop-until-budget: while ctx.remaining() > threshold { … }.

pub fn control_breach(&self) -> Option<ControlBreach>

The first run-level limit breach, if one has occurred.

Trait Implementations

impl Clone for WorkflowCtx

fn clone(&self) -> WorkflowCtx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkflowCtx

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.