Enum hydro_lang::ir::HydroNode

pub enum HydroNode {
    Placeholder,
    Source {
        source: HydroSource,
        location_kind: LocationId,
    },
    CycleSource {
        ident: Ident,
        location_kind: LocationId,
    },
    Tee {
        inner: TeeNode,
    },
    Persist(Box<HydroNode>),
    Unpersist(Box<HydroNode>),
    Delta(Box<HydroNode>),
    Chain(Box<HydroNode>, Box<HydroNode>),
    CrossProduct(Box<HydroNode>, Box<HydroNode>),
    CrossSingleton(Box<HydroNode>, Box<HydroNode>),
    Join(Box<HydroNode>, Box<HydroNode>),
    Difference(Box<HydroNode>, Box<HydroNode>),
    AntiJoin(Box<HydroNode>, Box<HydroNode>),
    Map {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    FlatMap {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    Filter {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    FilterMap {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    DeferTick(Box<HydroNode>),
    Enumerate {
        is_static: bool,
        input: Box<HydroNode>,
    },
    Inspect {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    Unique(Box<HydroNode>),
    Sort(Box<HydroNode>),
    Fold {
        init: DebugExpr,
        acc: DebugExpr,
        input: Box<HydroNode>,
    },
    FoldKeyed {
        init: DebugExpr,
        acc: DebugExpr,
        input: Box<HydroNode>,
    },
    Reduce {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    ReduceKeyed {
        f: DebugExpr,
        input: Box<HydroNode>,
    },
    Network {
        from_location: LocationId,
        from_key: Option<usize>,
        to_location: LocationId,
        to_key: Option<usize>,
        serialize_fn: Option<DebugExpr>,
        instantiate_fn: DebugInstantiate,
        deserialize_fn: Option<DebugExpr>,
        input: Box<HydroNode>,
    },
}

An intermediate node in a Hydro graph, which consumes data from upstream nodes and emits data to downstream nodes.

Variants

Placeholder

Source

Fields

source: HydroSource

location_kind: LocationId

CycleSource

Fields

ident: Ident

location_kind: LocationId

Tee

Fields

inner: TeeNode

Persist(Box<HydroNode>)

Unpersist(Box<HydroNode>)

Delta(Box<HydroNode>)

Chain(Box<HydroNode>, Box<HydroNode>)

CrossProduct(Box<HydroNode>, Box<HydroNode>)

CrossSingleton(Box<HydroNode>, Box<HydroNode>)

Join(Box<HydroNode>, Box<HydroNode>)

Difference(Box<HydroNode>, Box<HydroNode>)

AntiJoin(Box<HydroNode>, Box<HydroNode>)

Map

Fields

f: DebugExpr

input: Box<HydroNode>

FlatMap

Fields

f: DebugExpr

input: Box<HydroNode>

Filter

Fields

f: DebugExpr

input: Box<HydroNode>

FilterMap

Fields

f: DebugExpr

input: Box<HydroNode>

DeferTick(Box<HydroNode>)

Enumerate

Fields

is_static: bool

input: Box<HydroNode>

Inspect

Fields

f: DebugExpr

input: Box<HydroNode>

Unique(Box<HydroNode>)

Sort(Box<HydroNode>)

Fold

Fields

init: DebugExpr

acc: DebugExpr

input: Box<HydroNode>

FoldKeyed

Fields

init: DebugExpr

acc: DebugExpr

input: Box<HydroNode>

Reduce

Fields

f: DebugExpr

input: Box<HydroNode>

ReduceKeyed

Fields

f: DebugExpr

input: Box<HydroNode>

Network

Fields

from_location: LocationId

from_key: Option<usize>

to_location: LocationId

to_key: Option<usize>

serialize_fn: Option<DebugExpr>

instantiate_fn: DebugInstantiate

deserialize_fn: Option<DebugExpr>

input: Box<HydroNode>

Implementations

impl<'a> HydroNode

pub fn compile_network<D: Deploy<'a>>( &mut self, compile_env: &D::CompileEnv, seen_tees: &mut SeenTees, nodes: &HashMap<usize, D::Process>, clusters: &HashMap<usize, D::Cluster>, externals: &HashMap<usize, D::ExternalProcess>, )

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

pub fn transform_bottom_up<C>( &mut self, transform: impl FnMut(&mut HydroNode, &mut C) + Copy, seen_tees: &mut SeenTees, ctx: &mut C, )

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

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

Trait Implementations

impl Debug for HydroNode

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

Formats the value using the given formatter.