pub async fn run(
spec: &ReconcileSpec,
auth: &AuthCatalog,
written: u64,
) -> Result<(), FaucetError>Expand description
Run the count probe and reconcile it against written. Builds the probe
source through the registry (so any connector works and shared auth: { ref }
resolves), drains it, extracts the count, and evaluates. Returns
FaucetError::Source on a shortfall so the caller fails the run.