Struct FanOutState 

pub struct FanOutState {
    pub config: FanOutConfig,
    pub max_workers: usize,
    pub pending: Vec<WorkItem>,
    pub active: Vec<(String, String)>,
    pub summaries: Vec<(String, String)>,
    pub failures: Vec<(String, String)>,
}

The serializable form of FanOutWaiting, written to <run_dir>/fanout.json so a parent interrupted mid-split resumes its merge after a restart. active carries worker run-ids (not entities); recovery maps them back to the reloaded worker entities.

Fields

config: FanOutConfig

The fan-out configuration.

max_workers: usize

The concurrency cap.

pending: Vec<WorkItem>

Work items not yet started.

active: Vec<(String, String)>

In-flight workers as (item_id, run_id).

summaries: Vec<(String, String)>

Completed worker results as (item_id, summary).

failures: Vec<(String, String)>

Failed worker results as (item_id, message).

Trait Implementations

impl Clone for FanOutState

fn clone(&self) -> FanOutState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanOutState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FanOutState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FanOutState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.