Struct FanTask 

pub struct FanTask {
    pub name: String,
    pub timeout: Option<Duration>,
    pub weight: u32,
    /* private fields */
}

A single unit of work in a fan-out/fan-in pattern.

Each FanTask wraps a named async closure that receives shared context from the fan-out root and returns either a numeric output or an error string.

Fields

name: String

Human-readable name (used in result maps and error messages).

timeout: Option<Duration>

Optional per-task timeout. When None, the executor default is used.

weight: u32

Task weight used by weighted-sum aggregation (default = 1).

Implementations

impl FanTask

pub fn new<N, F, Fut>(name: N, factory: F) -> Self

where N: Into<String>, F: Fn(Arc<HashMap<String, String>>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<i64, String>> + Send + 'static,

Create a FanTask from an async factory closure.

The closure accepts the shared context and must return a Future<Output = Result<i64, String>>.

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

Set a per-task timeout.

pub fn with_weight(self, weight: u32) -> Self

Set the aggregation weight for this task (used with AggregationStrategy::WeightedSum).

Trait Implementations

impl Clone for FanTask

fn clone(&self) -> FanTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanTask

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

Formats the value using the given formatter.