Struct GraphBlueprint 

pub struct GraphBlueprint<S: Shape> { /* private fields */ }

An immutable, validated graph ready to run. Produced by GraphDsl::create/ try_create. Carries the external Shape, the stages, the wired edges, the precomputed fused segments, and graph-level Attributes. The run_* methods are defined in the executor module; running one never mutates the blueprint, so it can be reused and run concurrently.

Implementations

impl<S: Shape> GraphBlueprint<S>

pub fn shape(&self) -> S

pub fn stage_count(&self) -> usize

pub fn edge_count(&self) -> usize

pub fn segments(&self) -> &[FusedSegment]

pub fn attributes(&self) -> &Attributes

pub fn effective_stage_attributes(&self) -> Vec<FusedNodeAttributes>

Effective post-merge attributes for every stage in execution order.

Graph-level attributes are inherited by each stage and stage-level attributes override them per key, matching Akka’s closest-wins mental model.

pub fn with_attributes(self, attributes: Attributes) -> Self

pub fn add_attributes(self, attributes: Attributes) -> Self

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

impl<In, Out> GraphBlueprint<FlowShape<In, Out>>

where In: Clone + Send + 'static, Out: Send + 'static,

pub fn run_with_input<I>(&self, input: I) -> StreamResult<Vec<Out>>

where I: IntoIterator<Item = In>,

pub fn run_with_input_report<I>( &self, input: I, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<Out>>

where I: IntoIterator<Item = In>,

pub fn run_count_with_input<I>(&self, input: I) -> StreamResult<usize>

where I: IntoIterator<Item = In>,

pub fn run_count_with_input_report<I>( &self, input: I, config: FusedExecutionConfig, ) -> StreamResult<FusedTerminalReport<usize>>

where I: IntoIterator<Item = In>,

pub fn run_fold_with_input<I, Acc, F>( &self, input: I, zero: Acc, fold: F, ) -> StreamResult<Acc>

where I: IntoIterator<Item = In>, F: FnMut(Acc, Out) -> Acc,

pub fn run_fold_with_input_report<I, Acc, F>( &self, input: I, zero: Acc, fold: F, config: FusedExecutionConfig, ) -> StreamResult<FusedTerminalReport<Acc>>

where I: IntoIterator<Item = In>, F: FnMut(Acc, Out) -> Acc,

impl<T> GraphBlueprint<FlowShape<T, T>>

where T: Send + 'static,

pub fn run_typed_linear_with_input<I>(&self, input: I) -> StreamResult<Vec<T>>

where I: IntoIterator<Item = T>,

pub fn run_typed_linear_with_input_report<I>( &self, input: I, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

where I: IntoIterator<Item = T>,

pub fn run_typed_linear_count_with_input<I>( &self, input: I, ) -> StreamResult<usize>

where I: IntoIterator<Item = T>,

pub fn run_typed_linear_count_with_input_report<I>( &self, input: I, config: FusedExecutionConfig, ) -> StreamResult<FusedTerminalReport<usize>>

where I: IntoIterator<Item = T>,

pub fn run_typed_linear_fold_with_input<I, Acc, F>( &self, input: I, zero: Acc, fold: F, ) -> StreamResult<Acc>

where I: IntoIterator<Item = T>, F: FnMut(Acc, T) -> Acc,

pub fn run_typed_linear_fold_with_input_report<I, Acc, F>( &self, input: I, zero: Acc, fold: F, config: FusedExecutionConfig, ) -> StreamResult<FusedTerminalReport<Acc>>

where I: IntoIterator<Item = T>, F: FnMut(Acc, T) -> Acc,

pub fn run_async_boundary_count_with_input_report<I>( &self, input: I, config: AsyncBoundaryExecutionConfig, ) -> StreamResult<FusedTerminalReport<usize>>

where I: IntoIterator<Item = T> + Send, I::IntoIter: Send + 'static,

Runs the internal async-boundary count path.

The graph is still runtime-validated through the typed-linear plan, then split at AsyncBoundary stages and connected with bounded handoff. The concrete boundary executor is intentionally private so Datum does not expose multiple public runtime backends.

impl<T> GraphBlueprint<FanInShape<T, T>>

where T: Clone + Send + 'static,

pub fn run_fan_in(&self, inputs: Vec<Vec<T>>) -> StreamResult<Vec<T>>

pub fn run_fan_in_report( &self, inputs: Vec<Vec<T>>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

pub fn run_concat(&self, inputs: Vec<Vec<T>>) -> StreamResult<Vec<T>>

pub fn run_concat_report( &self, inputs: Vec<Vec<T>>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

pub fn run_or_else( &self, primary: Vec<T>, secondary: Vec<T>, ) -> StreamResult<Vec<T>>

pub fn run_or_else_report( &self, primary: Vec<T>, secondary: Vec<T>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

pub fn run_or_else_secondary_first( &self, primary: Vec<T>, secondary: Vec<T>, ) -> StreamResult<Vec<T>>

pub fn run_or_else_secondary_first_report( &self, primary: Vec<T>, secondary: Vec<T>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

pub fn run_or_else_secondary_closed_first( &self, secondary: Vec<T>, ) -> StreamResult<Vec<T>>

pub fn run_interleave( &self, inputs: Vec<Vec<T>>, segment_size: usize, eager_close: bool, ) -> StreamResult<Vec<T>>

pub fn run_interleave_report( &self, inputs: Vec<Vec<T>>, segment_size: usize, eager_close: bool, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

impl<T> GraphBlueprint<MergePreferredShape<T>>

where T: Clone + Send + 'static,

pub fn run_merge_preferred( &self, preferred: Vec<T>, secondary_inputs: Vec<Vec<T>>, ) -> StreamResult<Vec<T>>

pub fn run_merge_preferred_report( &self, preferred: Vec<T>, secondary_inputs: Vec<Vec<T>>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<T>>

impl<Left, Right> GraphBlueprint<ZipShape<Left, Right>>

where Left: Clone + Send + 'static, Right: Clone + Send + 'static,

pub fn run_zip( &self, left: Vec<Left>, right: Vec<Right>, ) -> StreamResult<Vec<(Left, Right)>>

pub fn run_zip_report( &self, left: Vec<Left>, right: Vec<Right>, config: FusedExecutionConfig, ) -> StreamResult<FusedExecutionReport<(Left, Right)>>

Trait Implementations

impl<S: Shape + Clone> Clone for GraphBlueprint<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Shape + Debug> Debug for GraphBlueprint<S>

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

Formats the value using the given formatter.

impl<S: Shape> Graph for GraphBlueprint<S>

type Shape = S

fn shape(&self) -> Self::Shape