faucet_cli/backfill/mod.rs
1//! `faucet backfill` — replay a bounded historical window of a pipeline
2//! (#282).
3//!
4//! A CLI-level orchestration layer (like `replication/` and `sla/`) over
5//! `expand` + `executor::run_expanded`: the requested range is chunked into
6//! independent window **units**, each unit re-runs the pipeline with its
7//! source config scoped to that window (`${backfill.start}` /
8//! `${backfill.end}` token substitution + a per-unit `${now.*}` clock), and a
9//! durable progress marker in the pipeline's state store makes the whole
10//! backfill resumable (`--resume`). Unit state keys are namespaced
11//! (`{name}::backfill::{unit}`) so the forward-sync bookmark is never
12//! touched.
13
14pub mod orchestrator;
15pub mod plan;
16pub mod spec;
17pub mod state;
18
19mod metrics;
20
21pub use orchestrator::{BackfillOptions, BackfillOutcome, BackfillRange, run_backfill};
22pub use spec::BackfillSpec;