Enum GraphEdge 

pub enum GraphEdge {
    Fixed {
        source: String,
        target: String,
    },
    Conditional {
        source: String,
        router_name: String,
        targets: HashMap<String, String>,
        default_target: Option<String>,
    },
    FanOut {
        source: String,
        targets: Vec<String>,
    },
    FanIn {
        sources: Vec<String>,
        target: String,
    },
}

Graph Edge enum

Represents a transition in the graph. Can be:

• Fixed: Always transitions to a specific node
• Conditional: Routes based on state via a routing function

Variants

Fixed

Fixed edge: always transitions to a specific target node.

Fields

source: String

Source node name.

target: String

Target node name.

Conditional

Conditional edge: routes to a target based on state via a routing function.

Fields

source: String

Source node name.

router_name: String

Name of the routing function used to select a target.

targets: HashMap<String, String>

Route key → target node name mapping.

default_target: Option<String>

Target used when no route key matches.

FanOut

FanOut edge: one source → multiple targets (parallel execution)

Fields

source: String

Source node name.

targets: Vec<String>

Target nodes to execute in parallel.

FanIn

FanIn edge: multiple sources → one target (join point)

Fields

sources: Vec<String>

Source nodes that join at this point.

target: String

Single target node after the join.

Implementations

impl GraphEdge

pub fn fixed(source: impl Into<String>, target: impl Into<String>) -> Self

Create a fixed edge from source to target.

pub fn conditional<R, T>( source: impl Into<String>, router_name: impl Into<String>, targets: HashMap<R, T>, default: Option<T>, ) -> Self

where R: Into<String>, T: Into<String>,

Create a conditional edge routed by a named routing function.

pub fn fan_out(source: impl Into<String>, targets: Vec<String>) -> Self

Create a FanOut edge with multiple parallel targets.

pub fn fan_in(sources: Vec<String>, target: impl Into<String>) -> Self

Create a FanIn edge joining multiple sources into one target.

pub fn source(&self) -> &str

Return the source node name (for FanIn returns "__fanin__").

pub fn fixed_target(&self) -> Option<&str>

Return the fixed target node, if this edge has one.

pub fn fan_out_targets(&self) -> Option<&Vec<String>>

Return the FanOut targets, if this is a FanOut edge.

pub fn fan_in_sources(&self) -> Option<&Vec<String>>

Return the FanIn sources, if this is a FanIn edge.

Trait Implementations

impl Clone for GraphEdge

fn clone(&self) -> GraphEdge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GraphEdge

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

Formats the value using the given formatter.