Struct FanOutEngine 

pub struct FanOutEngine { /* private fields */ }

Fan-out/fan-in engine for parallel distribution and result collection.

Implementations

impl FanOutEngine

pub fn new() -> Self

pub fn create_fanout( &mut self, destinations: Vec<FanOutDestination>, completion_policy: CompletionPolicy, aggregator: ResultAggregator, timeout_ms: Option<u64>, ) -> WorkflowResult<String>

Create a fan-out step.

pub fn start_execution( &mut self, fanout_id: &str, execution_id: &str, ) -> WorkflowResult<()>

Start executing a fan-out — creates branch tracking.

pub fn update_branch( &mut self, execution_id: &str, destination_id: &str, status: FanOutBranchStatus, output: Option<Value>, error: Option<String>, duration_ms: Option<u64>, ) -> WorkflowResult<()>

Update a branch status.

pub fn get_status(&self, execution_id: &str) -> WorkflowResult<&FanOutStatus>

Get fan-out status.

pub fn get_step(&self, fanout_id: &str) -> WorkflowResult<&FanOutStep>

Get a fan-out step definition.

Trait Implementations

impl Default for FanOutEngine

fn default() -> Self

Returns the “default value” for a type.