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.