Skip to main content

record_load

Function record_load 

Source
pub async fn record_load(
    contract: &Contract,
    endpoint: Endpoint,
    broker_image: String,
    lost: impl Future<Output = ()>,
    out: &Path,
) -> Result<LoadRecord>
Expand description

krabka-soak-drill load: run the load until lost, report each producer’s totals, and write the record to out.

§Errors

Consumer preparation fails, the source is lost before load starts, or the record cannot be written.