Struct DataflowGraph 

pub struct DataflowGraph { /* private fields */ }

A dataflow graph representing the transformation pipeline.

Implementations

impl DataflowGraph

pub fn new() -> Self

Create a new empty dataflow graph.

pub fn add_node(&mut self, node: Node) -> NodeId

Add a node to the graph.

Returns the node’s ID for connecting edges.

pub fn connect(&mut self, from: NodeId, to: NodeId) -> bool

Connect two nodes with an edge (from -> to).

Returns false if either node doesn’t exist.

pub fn get_node(&self, id: NodeId) -> Option<&Node>

Get a node by ID.

pub fn get_node_mut(&mut self, id: NodeId) -> Option<&mut Node>

Get a mutable node by ID.

pub fn get_node_by_name(&self, name: &str) -> Option<&Node>

Get a node by name.

pub fn get_id_by_name(&self, name: &str) -> Option<NodeId>

Get node ID by name.

pub fn outgoing(&self, id: NodeId) -> &[NodeId]

Get all outgoing edges from a node.

pub fn incoming(&self, id: NodeId) -> &[NodeId]

Get all incoming edges to a node.

pub fn node_count(&self) -> usize

Get the number of nodes.

pub fn edge_count(&self) -> usize

Get the number of edges.

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

Get all source nodes (no incoming edges).

pub fn sinks(&self) -> Vec<NodeId>

Get all sink nodes (no outgoing edges).

pub fn topological_sort(&self) -> Option<Vec<NodeId>>

Perform topological sort of the graph.

Returns None if the graph has cycles.

pub fn has_cycles(&self) -> bool

Check if the graph has any cycles.

pub fn reachable_from(&self, start: NodeId) -> HashSet<NodeId>

Find all nodes reachable from a given node.

pub fn nodes(&self) -> impl Iterator<Item = (NodeId, &Node)>

Iterate over all nodes.

Trait Implementations

impl Clone for DataflowGraph

fn clone(&self) -> DataflowGraph

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataflowGraph

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

Formats the value using the given formatter.

impl Default for DataflowGraph

fn default() -> Self

Returns the “default value” for a type.