Struct GraphBuilder 

pub struct GraphBuilder { /* private fields */ }

Builder for constructing dataflow graphs fluently.

Implementations

impl GraphBuilder

pub fn new() -> Self

Create a new graph builder.

pub fn source(self, name: impl Into<String>) -> Self

Add a source node.

pub fn project( self, name: impl Into<String>, projection_type: impl Into<String>, ) -> Self

Add a projection node, connecting from the last node.

pub fn transform( self, name: impl Into<String>, transform_type: TransformType, ) -> Self

Add a transform node, connecting from the last node.

pub fn sink( self, name: impl Into<String>, target_property: impl Into<String>, ) -> Self

Add a sink node, connecting from the last node.

pub fn from(self, name: &str) -> Self

Branch from a named node (for multiple paths).

pub fn build(self) -> DataflowGraph

Build and return the graph.

Trait Implementations

impl Default for GraphBuilder

fn default() -> Self

Returns the “default value” for a type.