Struct Topology 

pub struct Topology { /* private fields */ }

A directed acyclic graph of typed nodes.

Build one with Topology::builder, then drive it with Topology::run.

Implementations

impl Topology

pub fn builder() -> TopologyBuilder

Start building a topology.

pub fn nodes(&self) -> &[Node]

The nodes, in insertion order.

pub fn edges(&self) -> &[Edge]

The edges, in insertion order.

pub fn validate(&self) -> Result<(), FaucetError>

Validate the graph: unique ids, existing endpoints, per-kind arity, tee fan-out, join edge labels, acyclicity, and source→sink reachability. Returns FaucetError::Config with a descriptive message on the first violation.

pub async fn run( self, opts: TopologyOptions, ) -> Result<TopologyResult, FaucetError>

Run the topology to completion with no governance passes.

Equivalent to Topology::run_with with a default TopologyGovernance — kept as-is so existing callers are unaffected.

pub async fn run_with( self, opts: TopologyOptions, governance: TopologyGovernance, ) -> Result<TopologyResult, FaucetError>

Run the topology to completion, applying governance to every sink node.

Separate from Topology::run rather than a field on TopologyOptions: that struct is exhaustively constructible through the public API, so adding a field to it would be a major-version break for every downstream crate. A new method is additive.

pub async fn run_reported( self, opts: TopologyOptions, governance: TopologyGovernance, ) -> Result<TopologyRun, FaucetError>

Topology::run_with with per-node attribution.

The CLI emits notifications and evaluates SLAs per sink node, which needs to know which node failed; TopologyResult::errors is only a flat list of messages. Additive rather than a change to run_with’s return type, which would break every caller (#459).

Trait Implementations

impl Debug for Topology

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

Formats the value using the given formatter.