Struct hydro_lang::builder::FlowBuilder

pub struct FlowBuilder<'a> { /* private fields */ }

Implementations

impl<'a> FlowBuilder<'a>

pub fn new() -> FlowBuilder<'a>

pub fn finalize(self) -> BuiltFlow<'a>

pub fn with_default_optimize<D: LocalDeploy<'a>>(self) -> DeployFlow<'a, D>

pub fn optimize_with( self, f: impl FnOnce(Vec<HydroLeaf>) -> Vec<HydroLeaf>, ) -> BuiltFlow<'a>

pub fn flow_state(&self) -> &FlowState

pub fn process<P>(&self) -> Process<'a, P>

pub fn external_process<P>(&self) -> ExternalProcess<'a, P>

pub fn cluster<C>(&self) -> Cluster<'a, C>

pub fn with_process<P, D: LocalDeploy<'a>>( self, process: &Process<'_, P>, spec: impl IntoProcessSpec<'a, D>, ) -> DeployFlow<'a, D>

pub fn with_external<P, D: LocalDeploy<'a>>( self, process: &ExternalProcess<'_, P>, spec: impl ExternalSpec<'a, D>, ) -> DeployFlow<'a, D>

pub fn with_cluster<C, D: LocalDeploy<'a>>( self, cluster: &Cluster<'_, C>, spec: impl ClusterSpec<'a, D>, ) -> DeployFlow<'a, D>

pub fn compile<D: Deploy<'a>>( self, env: &D::CompileEnv, ) -> CompiledFlow<'a, D::GraphId>

pub fn compile_no_network<D: LocalDeploy<'a>>( self, ) -> CompiledFlow<'a, D::GraphId>

pub fn deploy<D: Deploy<'a, CompileEnv = ()>>( self, env: &mut D::InstantiateEnv, ) -> DeployResult<'a, D>

Trait Implementations

impl Drop for FlowBuilder<'_>

fn drop(&mut self)

Executes the destructor for this type.

impl QuotedContext for FlowBuilder<'_>

fn create() -> Self