Skip to main content

Module topology

Module topology 

Source
Expand description

Topology mode (issues #71 / #72): build and run a faucet_core::Topology from a config’s pipeline.nodes / edges block.

When pipeline.nodes is non-empty the pipeline runs as an explicit node graph rather than a matrix. This module resolves each node’s connector templates, compiles its transforms, wires the edges, and drives the core topology executor — reusing crate::registry for connector construction and crate::state / crate::executor::build_dlq_config for the sink-side plumbing.

Functions§

build_topology
Build a faucet_core::Topology from the config’s pipeline.nodes / edges block.
is_topology
Whether the config selects topology mode (a non-empty pipeline.nodes).
preview
Preview topology mode: build each source node and print the first limit records per source to stdout as JSON Lines.
preview_records
Collect a bounded preview of each source node’s records (source side only; downstream nodes are not run). Returns (node_id, records) per source node, in sorted node-id order.
preview_to_string
Preview topology sources into a JSON string (for the MCP preview tool).
run_topology
Build and run the topology, returning a RunSummary shaped like a matrix run (one invocation per sink node, plus one per node failure under on_error: continue).