Enum NodeRole 

pub enum NodeRole {
    Root,
    Child {
        parent_id: String,
        parent_key: String,
    },
    Discovery {
        select: String,
        as_alias: String,
        collect: bool,
        dims: Vec<String>,
    },
    Product {
        dims: Vec<String>,
        collected: Vec<String>,
    },
}

Variants

Root

Root node — runs once per pipeline invocation.

Child

Child node — runs once per record produced by the parent row.

Fields

parent_id: String

parent_key: String

Discovery

Discovery dimension (#501) — runs its source once, projects select, dedups, and publishes the value-set under as_alias. No sink.

Chained / collected discovery (#531): when dims is non-empty the discovery is itself fanned out over the cartesian product of those upstream discovery dimensions (its for_each), running once per tuple with ${dim} tokens resolved in its source config; with collect: true each tuple’s value-set is published as one list keyed by the tuple (a CollectedDim) rather than as a flat cartesian axis.

Fields

select: String

as_alias: String

collect: bool

dims: Vec<String>

Product

Discovery-driven fan-out (#501) — runs once per tuple of the cartesian product of the named discovery dimensions. dims are discovery row ids (also mirrored into depends_on for readiness/skip/cycle reuse). collected (#531) names the collected discovery rows this row references (${id.alias}), whose per-tuple lists are injected into each tuple ctx.

Fields

dims: Vec<String>

collected: Vec<String>

Trait Implementations

impl Clone for NodeRole

fn clone(&self) -> NodeRole

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeRole

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

Formats the value using the given formatter.