Skip to main content

Module runner

Module runner 

Source
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.
ResolvedCase
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 in CaseRun::error.