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::Topologyfrom the config’spipeline.nodes/edgesblock. - is_
topology - Whether the config selects topology mode (a non-empty
pipeline.nodes). - preview
- Preview topology mode: build each
sourcenode and print the firstlimitrecords per source to stdout as JSON Lines. - preview_
records - Collect a bounded preview of each
sourcenode’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
previewtool). - run_
topology - Build and run the topology, returning a
RunSummaryshaped like a matrix run (one invocation per sink node, plus one per node failure underon_error: continue).