Expand description
Offline pipeline execution for faucet test.
Runs the deterministic slice of a pipeline — transforms → quality →
contract — through the real faucet_core::Pipeline streaming loop, with
the configured source and sink replaced by in-memory fixtures/captures.
Because the genuine per-page code path runs (including DLQ routing and
abort semantics), what a test observes is exactly what production would do
for the same records.
Structs§
- CaseRun
- Everything a run produced, for the expectation pass.
- Resolved
Case - A test case with its pipeline logic and fixtures fully resolved — the runner’s only input, shared by the config-file and inline paths.
Functions§
- run_
case - Execute one resolved case fully offline. Only setup problems (an invalid
transform config) surface as
Err; a failing pipeline run is a legitimate, assertable outcome and lands inCaseRun::error.