Struct RunOptions 

#[non_exhaustive]
pub struct RunOptions<'a> {

    pub channel: Option<&'a str>,
    pub routing_bucket: Option<u8>,
    pub capture_changes: bool,
    pub audit: AuditMode,
    pub deadline: Option<Instant>,
    pub cancel: Option<&'a CancelToken>,
    pub layers: &'a [Arc<dyn CallLayer>],
    pub observer: Option<&'a dyn Observer>,
    pub trace: Option<TraceOptions>,
    pub condition_error_policy: Option<ConditionErrorPolicy>,
    pub task_budget: Option<u64>,
    pub expr_ops_budget: Option<u64>,
    pub accountant: Option<&'a dyn RunAccountant>,
}

What a caller chooses about one run.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

channel: Option<&'a str>

Run the Active workflows of this channel; None runs every Active one.

routing_bucket: Option<u8>

The bucket a rollout admits, 0..=99; a larger one is served as 99. None is admitted by every rollout.

capture_changes: bool

Record each write’s Change in its task’s audit entry. true by default (#63). It governs only the audit trail: a trace records its own changes whatever it says.

audit: AuditMode

Which audit entries the message keeps. Full by default.

deadline: Option<Instant>

When the run must end; None by default. It is checked at every host call, every fan-out element’s start, every sweep and every CHECK_EVERY ops. Natively each host call also races it, on a Tokio timer, so a run with a deadline is polled inside a Tokio runtime with its time driver enabled. A call it cuts short, or that returns Err once it has passed, is recorded as TIMEOUT_ERROR on its task; either way the run ends TimedOut.

On wasm no timer exists, so nothing races a host call and it is never cut short mid-flight: a deadline that passes while a call runs is seen at the next check, after the call returns.

cancel: Option<&'a CancelToken>

A token that cancels the run when it, or an ancestor, is cancelled; None by default. It is checked and raced where the deadline is, and first. A call it cuts short, or that returns Err once it is cancelled, is recorded as CANCELLED on its task; either way the run ends Cancelled.

layers: &'a [Arc<dyn CallLayer>]

Layers around every host call of this run, outside the registry’s; the first is the outermost. None by default.

observer: Option<&'a dyn Observer>

An observer of this run, beside the engine’s (EngineConfig::observer); None by default.

trace: Option<TraceOptions>

Trace the run, as these options say: its Run::trace is then the initial context plus each step’s changes. None by default: no trace, and no copy of the context.

condition_error_policy: Option<ConditionErrorPolicy>

How condition evaluation errors are handled during this run; None inherits the engine’s EngineConfig::condition_error_policy (which defaults to ConditionErrorPolicy::Skip).

task_budget: Option<u64>

Maximum number of task dispatches (inline built-ins, host calls, loop sweeps, and for_each elements) permitted during this run; None by default.

expr_ops_budget: Option<u64>

Maximum cumulative datalogic operations permitted across all expressions evaluated during this run; None by default.

accountant: Option<&'a dyn RunAccountant>

Host-owned accounting and admission hook for this run; None by default.

Implementations

impl<'a> RunOptions<'a>

pub fn channel(self, c: &'a str) -> Self

Runs the Active workflows of channel c.

pub fn routing_bucket(self, b: u8) -> Self

Sets the routing bucket rollouts are tested against: 0..=99. A larger one is served as bucket 99, as in 3.x, so derive it as a hash % 100, never % 256.

pub fn capture_changes(self, on: bool) -> Self

Turns the audit trail’s change capture on or off.

pub fn audit(self, mode: AuditMode) -> Self

Sets which audit entries the message keeps.

pub fn deadline(self, deadline: Instant) -> Self

Ends the run at deadline, as the deadline field says.

pub fn cancel(self, token: &'a CancelToken) -> Self

Cancels the run when token is cancelled, as the cancel field says.

pub fn layers(self, layers: &'a [Arc<dyn CallLayer>]) -> Self

Wraps every host call of the run in layers, outside the registry’s layers; the first is the outermost.

pub fn observer(self, o: &'a dyn Observer) -> Self

Reports this run to o too, beside the engine’s observer.

pub fn trace(self, opts: TraceOptions) -> Self

Traces the run under opts, as the trace field says.

pub fn condition_error_policy(self, policy: ConditionErrorPolicy) -> Self

Sets how condition evaluation errors are handled during this run.

pub fn with_condition_error_policy(self, policy: ConditionErrorPolicy) -> Self

Alias for Self::condition_error_policy.

pub fn task_budget(self, max_tasks: u64) -> Self

Sets the maximum number of task dispatches permitted during this run.

pub fn with_task_budget(self, max_tasks: u64) -> Self

Alias for Self::task_budget.

pub fn expr_ops_budget(self, max_ops: u64) -> Self

Sets the maximum cumulative datalogic operations permitted across all expressions evaluated during this run.

pub fn with_expr_ops_budget(self, max_ops: u64) -> Self

Alias for Self::expr_ops_budget.

pub fn accountant(self, accountant: &'a dyn RunAccountant) -> Self

Attaches a host-owned RunAccountant to this run.

pub fn with_accountant(self, accountant: &'a dyn RunAccountant) -> Self

Alias for Self::accountant.

Trait Implementations

impl<'a> Clone for RunOptions<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunOptions<'_>

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

Every option, the layers as a count and the observer as a presence.

impl Default for RunOptions<'_>

fn default() -> Self

Returns the “default value” for a type.