Struct FanExecutor 

pub struct FanExecutor {
    pub global_timeout: Option<Duration>,
}

Drives concurrent fan-out / fan-in execution.

FanExecutor is stateless and can be reused across multiple FanPattern executions.

Fields

global_timeout: Option<Duration>

Global default timeout applied when neither the task nor the pattern specifies one.

Implementations

impl FanExecutor

pub fn new() -> Self

Create a new executor with no global timeout.

pub fn with_global_timeout(self, timeout: Duration) -> Self

Set a global default timeout.

pub async fn execute( &self, pattern: FanPattern, ) -> Result<FanInResult, FanError>

Execute a FanPattern and return the aggregated FanInResult.

Errors

Returns FanError::AllFailed when every task fails and the strategy requires at least one success. Returns FanError::SomeFailed under CollectAll when any task fails. Returns FanError::TaskTimeout when a task exceeds its timeout.

Trait Implementations

impl Clone for FanExecutor

fn clone(&self) -> FanExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FanExecutor

fn default() -> FanExecutor

Returns the “default value” for a type.