Function mz_storage::source::source_reader_pipeline::synthesize_probes

fn synthesize_probes<G>(
    source_id: GlobalId,
    progress: &Stream<G, Infallible>,
    interval: Duration,
    now_fn: NowFn,
) -> Stream<G, Probe<G::Timestamp>>
where
    G: Scope,

Synthesizes a probe stream that produces the frontier of the given progress stream at the given interval.

This is used as a fallback for sources that don’t support probing the frontier of the upstream system.