Struct DeferredNodeConfig 

pub struct DeferredNodeConfig {
    pub merge_strategy: MergeStrategy,
    pub fan_in_timeout: Option<Duration>,
}

Configuration for a deferred (fan-in) node.

A deferred node waits for all upstream parallel paths to complete before executing. The configuration controls how outputs are merged and how long the node waits.

Example

use std::time::Duration;
use adk_graph::deferred::{DeferredNodeConfig, MergeStrategy};

let config = DeferredNodeConfig {
    merge_strategy: MergeStrategy::MergeMap,
    fan_in_timeout: Some(Duration::from_secs(60)),
};

Fields

merge_strategy: MergeStrategy

Strategy for combining upstream outputs.

fan_in_timeout: Option<Duration>

Maximum time to wait for all upstream paths to complete.

• None: Wait indefinitely for all upstream paths.
• Some(duration): If the timeout expires and some paths have completed, proceed with partial results. If zero paths have completed, return GraphError::FanInTimedOut.

Trait Implementations

impl Clone for DeferredNodeConfig

fn clone(&self) -> DeferredNodeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeferredNodeConfig

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

Formats the value using the given formatter.

impl Default for DeferredNodeConfig

fn default() -> DeferredNodeConfig

Returns the “default value” for a type.