Struct Workflow 

pub struct Workflow { /* private fields */ }

A symbolic computation graph under construction.

Implementations

impl Workflow

pub fn compile(&self) -> Result<CompiledWorkflow, WorkflowError>

Validates and optimizes this graph into a reusable physical plan.

Compilation performs type and cycle validation, stable topological ordering, common-subexpression elimination, dead-node elimination, output-lifetime planning and a conservative memory estimate.

Errors

Returns an error for a graph with no outputs, an invalid dependency, an incompatible dependency type or a cycle.

impl Workflow

pub fn new() -> Self

Starts an empty workflow.

pub fn input<T: Send + Sync + 'static>( &mut self, name: impl Into<Box<str>>, cost: Cost, ) -> Result<Input<T>, WorkflowBuildError>

Declares a typed named input.

Errors

Returns an error when the name is empty or already used by an input.

pub fn map<A, T, F>( &mut self, input: Node<A>, metadata: OperationMetadata, kernel: F, ) -> Result<Node<T>, WorkflowBuildError>

where A: Send + Sync + 'static, T: Send + Sync + 'static, F: Fn(&A, &ExecutionContext) -> WorkflowResult<T> + Send + Sync + 'static,

Adds one typed unary operation.

Errors

Returns an error when input belongs to another workflow.

pub fn map2<A, B, T, F>( &mut self, first: Node<A>, second: Node<B>, metadata: OperationMetadata, kernel: F, ) -> Result<Node<T>, WorkflowBuildError>

where A: Send + Sync + 'static, B: Send + Sync + 'static, T: Send + Sync + 'static, F: Fn(&A, &B, &ExecutionContext) -> WorkflowResult<T> + Send + Sync + 'static,

Adds one typed binary operation.

Errors

Returns an error when either input belongs to another workflow.

pub fn output<T: Send + Sync + 'static>( &mut self, name: impl Into<Box<str>>, node: Node<T>, ) -> Result<Output<T>, WorkflowBuildError>

Publishes a typed node under a stable output name.

Errors

Returns an error for an empty/duplicate name or a foreign node.

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Workflow

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

Formats the value using the given formatter.

impl Default for Workflow

fn default() -> Self

Returns the “default value” for a type.