Struct EventDrivenWorkflow

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

A workflow that processes events using event-driven nodes

Implementations

impl<Event, Context, Action> EventDrivenWorkflow<Event, Context, Action>

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

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

Create a new event-driven workflow with an initial node

pub fn add_node( &mut self, node: Arc<Mutex<dyn EventDrivenNode<Event, 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 fn set_route_with_validation( &mut self, from_id: &NodeId, action: Action, to_id: &NodeId, ) -> Result<(), FloxideError>

Sets a route with validation to ensure proper event flow

This method ensures that processor nodes (non-event sources) route back to valid event sources, preventing the “not an event source” error during execution.

Arguments

• from_id - The source node ID
• action - The action that triggers this route
• to_id - The destination node ID

Returns

• Result<(), FloxideError> - Ok if the route is valid, Error otherwise

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

Execute the workflow, processing events until the termination action is returned

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

Execute the workflow with a timeout