Enum EdgeGroup 

pub enum EdgeGroup {
    Single {
        source: String,
        target: String,
        condition: Option<Arc<dyn Fn(&Value) -> Pin<Box<dyn Future<Output = bool> + Send>> + Sync + Send>>,
    },
    FanOut {
        source: String,
        targets: Vec<String>,
        selection: Option<Arc<dyn Fn(&Value, &[String]) -> Pin<Box<dyn Future<Output = Vec<String>> + Send>> + Sync + Send>>,
        case_labels: Option<Vec<String>>,
    },
    FanIn {
        sources: Vec<String>,
        target: String,
    },
}

A group of edges sharing routing semantics. Rust equivalent of the EdgeGroup hierarchy.

Variants

Single

A single conditional edge from source to target.

Fields

source: String

target: String

condition: Option<Arc<dyn Fn(&Value) -> Pin<Box<dyn Future<Output = bool> + Send>> + Sync + Send>>

FanOut

Broadcast from source to all targets (optionally filtered by a selection function — used for switch/case and multi-selection).

case_labels, when present, is index-aligned with targets and carries human-readable labels for visualization (e.g. switch-case names). It has no effect on routing.

Fields

source: String

targets: Vec<String>

selection: Option<Arc<dyn Fn(&Value, &[String]) -> Pin<Box<dyn Future<Output = Vec<String>> + Send>> + Sync + Send>>

case_labels: Option<Vec<String>>

FanIn

Barrier: target runs once all sources have delivered, receiving the collected messages as a JSON array.

Fields

sources: Vec<String>

target: String

Implementations

impl EdgeGroup

pub fn sources(&self) -> Vec<String>

The source executor ids for this group.

pub fn targets(&self) -> Vec<String>

The target executor ids for this group.

pub fn has_condition(&self) -> bool

Whether this edge group carries a runtime routing predicate — a Single edge’s condition or a FanOut group’s selection — as opposed to being an unconditional edge, a plain broadcast, or a fan-in barrier (which never carries one). Mirrors upstream’s Edge.has_condition.

Trait Implementations

impl Clone for EdgeGroup

fn clone(&self) -> EdgeGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.