Struct Workflow

pub struct Workflow<Context, A = DefaultAction, Output = ()>
where
    A: ActionType,
{ /* private fields */ }

A workflow composed of connected nodes

Implementations

impl<Context, A, Output> Workflow<Context, A, Output>

where Context: Send + Sync + 'static, A: ActionType + Debug + Default + Clone + Send + Sync + 'static, Output: Send + Sync + 'static + Debug,

pub fn new<N>(start_node: N) -> Self

where N: Node<Context, A, Output = Output> + 'static,

Create a new workflow with the given start node

pub fn add_node<N>(&mut self, node: N) -> &mut Self

where N: Node<Context, A, Output = Output> + 'static,

Add a node to the workflow

pub fn connect(&mut self, from: &NodeId, action: A, to: &NodeId) -> &mut Self

Connect a node to another node with an action

pub fn set_default_route(&mut self, from: &NodeId, to: &NodeId) -> &mut Self

Set a default route from one node to another (used when no specific action matches)

pub fn get_node( &self, id: NodeId, ) -> Option<&dyn Node<Context, A, Output = Output>>

Get a node by its ID

pub async fn execute(&self, ctx: &mut Context) -> Result<Output, WorkflowError>

Execute the workflow with the given context

Trait Implementations

impl<Context, A, Output> Clone for Workflow<Context, A, Output>

where Context: Send + Sync + 'static, A: ActionType + Clone + Send + Sync + 'static, Output: Send + Sync + 'static,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.