Struct DeployFlow 

pub struct DeployFlow<'a, D>
where
    D: Deploy<'a>,
{ /* private fields */ }

Available on crate feature build only.

Implementations

impl<'a, D: Deploy<'a>> DeployFlow<'a, D>

pub fn ir(&self) -> &Vec<HydroRoot>

pub fn with_process_id_name( self, process_id: usize, process_name: String, spec: impl IntoProcessSpec<'a, D>, ) -> Self

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

pub fn with_remaining_processes<S: IntoProcessSpec<'a, D> + 'a>( self, spec: impl Fn() -> S, ) -> Self

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

pub fn with_remaining_externals<S: ExternalSpec<'a, D> + 'a>( self, spec: impl Fn() -> S, ) -> Self

pub fn with_cluster_id_name( self, cluster_id: usize, cluster_name: String, spec: impl ClusterSpec<'a, D>, ) -> Self

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

pub fn with_remaining_clusters<S: ClusterSpec<'a, D> + 'a>( self, spec: impl Fn() -> S, ) -> Self

pub fn preview_compile(&mut self) -> CompiledFlow<'a>

Compiles the flow into DFIR (dfir_lang::graph::DfirGraph) without networking. Useful for generating Mermaid diagrams of the DFIR.

(This returned DFIR will not compile due to the networking missing).

impl<'a, D: Deploy<'a>> DeployFlow<'a, D>

pub fn compile(&mut self) -> CompiledFlow<'a>

Compiles the flow into DFIR (dfir_lang::graph::DfirGraph) including networking.

(This does not compile the DFIR itself, instead use Self::deploy to compile & deploy the DFIR).

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

Compiles and deploys the flow.

Rough outline of steps:

• Compiles the Hydro into DFIR.
• Instantiates nodes as configured.
• Compiles the corresponding DFIR into binaries for nodes as needed.
• Connects up networking as needed.