Struct WorkflowHost 

pub struct WorkflowHost { /* private fields */ }

A parsed, validated and compiled workflow. Assembly is the only constructor, so a long-running host cannot accidentally skip static validation.

Implementations

impl WorkflowHost

pub fn assemble( spec_json: &str, registry: &NodeRegistry, ) -> Result<Self, HostError>

Parse, validate and compile a spec from JSON.

pub fn from_spec( spec: &Spec, registry: &NodeRegistry, ) -> Result<Self, HostError>

Validate and compile every branch of spec.

pub fn spec_id(&self) -> &str

Spec id.

pub fn branch_id(&self) -> &str

Id of the first (root) branch.

pub fn branch_ids(&self) -> impl Iterator<Item = &str>

Every branch id.

pub fn branch_count(&self) -> usize

Number of branches.

pub fn context(&self, state: Arc<dyn State>) -> WorkflowContext

Context for the root branch over state.

pub fn context_for( &self, branch_id: &str, state: Arc<dyn State>, ) -> WorkflowContext

Context for branch_id over state.

pub async fn run_event( &self, ctx: &WorkflowContext, event: Event, ) -> Option<RunOutcome>

Drive one event through the context’s branch.

pub async fn run_event_on( &self, branch_id: &str, ctx: &WorkflowContext, event: Event, ) -> Option<RunOutcome>

Drive one event through branch_id; None when the branch does not exist.