Skip to main content

run

Function run 

Source
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.