Module pipeline 

Layer: Coordinator (planning → execution → persistence/observability)

pipeline/mod.rs is the only module allowed to bridge all three layers. It reads a resolved plan (planning), dispatches to execution modules, then records metrics and sends notifications (persistence/observability).

See docs/adr/0003-layer-classification.md for the full module taxonomy.

Structs

RunOptions

Per-run configuration flags passed from the CLI to the pipeline.

RunSummary

Accumulates operational data during a pipeline run for summary and metrics.

ValidateTarget

Re-targeting overrides for rivet validate.

Enums

PlanOutputFormat

Output format for rivet plan.

ReconcileOutputFormat

Output format for the reconcile report.

RepairOutputFormat

Output format for the repair plan / report.

RepairReportSource

Source of the reconcile report used to derive the repair plan.

ValidateDepth

How deep a rivet validate pass goes — a graded verify layer over the same checks, letting an operator trade thoroughness for latency / cost.

ValidateOutputFormat

Output format mirroring the rivet reconcile / rivet repair pattern.

Functions

reset_chunk_checkpoint

reset_chunk_checkpoints_stuck

Clear chunk checkpoints for every export named in config_path’s YAML that currently has an in_progress chunk run (chunk_run.status = 'in_progress').

reset_state

run

run_apply_command

Entry point for rivet apply <plan-file> [--parallel-export-processes] [--resume] [--force].

run_plan_command

Entry point for rivet plan.

run_reconcile_command

run_repair_command

run_validate_command

Driver for rivet validate <export> (or every export when export_name is None).

show_chunk_checkpoint

show_files

show_journal

Display recent run journal entries for an export.

show_metrics

show_progression

Epic G / ADR-0008 — explicit committed / verified boundaries per export.

show_state