Struct FanOutConfig 

pub struct FanOutConfig {
    pub worker_agent: Option<String>,
    pub worker_stage: Option<String>,
    pub worker_query: Option<String>,
    pub merge_stage: Option<String>,
    pub max_workers: usize,
    pub on_worker_failure: WorkerFailurePolicy,
    pub split_prompt: String,
    pub results_region: Option<String>,
    pub max_items: Option<usize>,
}

Configuration for a StageMode::FanOut stage.

Exactly one of worker_agent / worker_stage / worker_query selects the worker’s agent type (validated when the blueprint’s graph is checked).

Fields

worker_agent: Option<String>

A separate registered/installed blueprint run as the worker agent type.

worker_stage: Option<String>

A stage in this blueprint (self-as-agent-type); must be marked allow_as_worker = true.

worker_query: Option<String>

Discovery hint matched against installed agent types.

merge_stage: Option<String>

Optional stage that reconciles worker results before transitioning.

max_workers: usize

Maximum number of workers running concurrently.

on_worker_failure: WorkerFailurePolicy

How to handle worker failures.

split_prompt: String

Prompt that produces the JSON array of work items (one per worker).

results_region: Option<String>

Context region the consolidated worker report is written to. None means conversation.

Worth naming when the results are bulky. conversation is a sliding window carrying the message history, so a large report competes with the turns around it and can be evicted by them. A region of its own gets a budget of its own, and that budget is what each worker’s share is divided from.

max_items: Option<usize>

Most work items the split may produce. None means however many it produces.

Distinct from max_workers, which caps how many run at once. This caps how many there are at all, which is what bounds both the run’s cost and each worker’s share of the results region: split a hundred ways and every worker’s contribution is a hundredth of the space.

Trait Implementations

impl Clone for FanOutConfig

fn clone(&self) -> FanOutConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanOutConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FanOutConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for FanOutConfig

impl PartialEq for FanOutConfig

fn eq(&self, other: &FanOutConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for FanOutConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FanOutConfig