Struct TimerWorkflow

pub struct TimerWorkflow<Context, Action>
where
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Default + Debug,
{ /* private fields */ }

A timer workflow that orchestrates execution of timer nodes

Implementations

impl<Context, Action> TimerWorkflow<Context, Action>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default + Debug,

pub fn new( initial_node: Arc<dyn TimerNode<Context, Action>>, termination_action: Action, ) -> Self

Create a new timer workflow with an initial node

pub fn add_node(&mut self, node: Arc<dyn TimerNode<Context, Action>>)

Add a node to the workflow

pub fn set_route(&mut self, from_id: &NodeId, action: Action, to_id: &NodeId)

Set a route from one node to another based on an action

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

Execute the workflow until completion or error