Enum HydroRoot 

pub enum HydroRoot {
    ForEach {
        f: DebugExpr,
        input: Box<HydroNode>,
        op_metadata: HydroIrOpMetadata,
    },
    SendExternal {
        to_external_id: usize,
        to_key: usize,
        to_many: bool,
        serialize_fn: Option<DebugExpr>,
        instantiate_fn: DebugInstantiate,
        input: Box<HydroNode>,
        op_metadata: HydroIrOpMetadata,
    },
    DestSink {
        sink: DebugExpr,
        input: Box<HydroNode>,
        op_metadata: HydroIrOpMetadata,
    },
    CycleSink {
        ident: Ident,
        input: Box<HydroNode>,
        out_location: LocationId,
        op_metadata: HydroIrOpMetadata,
    },
}

An root in a Hydro graph, which is an pipeline that doesn’t emit any downstream values. Traversals over the dataflow graph and generating DFIR IR start from roots.

Variants

ForEach

Fields

f: DebugExpr

input: Box<HydroNode>

op_metadata: HydroIrOpMetadata

SendExternal

Fields

to_external_id: usize

to_key: usize

to_many: bool

serialize_fn: Option<DebugExpr>

instantiate_fn: DebugInstantiate

input: Box<HydroNode>

op_metadata: HydroIrOpMetadata

DestSink

Fields

sink: DebugExpr

input: Box<HydroNode>

op_metadata: HydroIrOpMetadata

CycleSink

Fields

ident: Ident

input: Box<HydroNode>

out_location: LocationId

op_metadata: HydroIrOpMetadata

Implementations

impl HydroRoot

pub fn compile_network<'a, D>( &mut self, compile_env: &D::CompileEnv, extra_stmts: &mut BTreeMap<usize, Vec<Stmt>>, seen_tees: &mut SeenTees, processes: &HashMap<usize, D::Process>, clusters: &HashMap<usize, D::Cluster>, externals: &HashMap<usize, D::External>, )

where D: Deploy<'a>,

pub fn connect_network(&mut self, seen_tees: &mut SeenTees)

pub fn transform_bottom_up( &mut self, transform_root: &mut impl FnMut(&mut HydroRoot), transform_node: &mut impl FnMut(&mut HydroNode), seen_tees: &mut SeenTees, check_well_formed: bool, )

pub fn transform_children( &mut self, transform: impl FnMut(&mut HydroNode, &mut SeenTees), seen_tees: &mut SeenTees, )

pub fn deep_clone(&self, seen_tees: &mut SeenTees) -> HydroRoot

pub fn emit( &mut self, graph_builders: &mut BTreeMap<usize, FlatGraphBuilder>, built_tees: &mut HashMap<*const RefCell<HydroNode>, (Ident, usize)>, next_stmt_id: &mut usize, )

pub fn emit_core( &mut self, builders_or_callback: &mut BuildersOrCallback<'_, impl FnMut(&mut HydroRoot, &mut usize), impl FnMut(&mut HydroNode, &mut usize)>, built_tees: &mut HashMap<*const RefCell<HydroNode>, (Ident, usize)>, next_stmt_id: &mut usize, )

pub fn op_metadata(&self) -> &HydroIrOpMetadata

pub fn op_metadata_mut(&mut self) -> &mut HydroIrOpMetadata

pub fn input_metadata(&self) -> Vec<&HydroIrMetadata>

pub fn print_root(&self) -> String

pub fn visit_debug_expr(&mut self, transform: impl FnMut(&mut DebugExpr))

impl HydroRoot

pub fn write_graph<W>( &self, graph_write: W, config: &HydroWriteConfig, ) -> Result<(), W::Err>

where W: HydroGraphWrite,

Available on crate feature viz only.

Core graph writing logic that works with any GraphWrite implementation.

pub fn build_graph_structure( &self, structure: &mut HydroGraphStructure, seen_tees: &mut HashMap<*const RefCell<HydroNode>, usize>, config: &HydroWriteConfig, ) -> usize

Available on crate feature viz only.

Build the graph structure by traversing the IR tree.

Trait Implementations

impl Debug for HydroRoot

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

Formats the value using the given formatter.

impl Hash for HydroRoot

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.