Skip to main content

run_load

Function run_load 

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

Run the contract’s load until lost completes or the contract’s duration elapses, and record every acknowledgement and commit with its time.

When lost completes first, every send in flight is abandoned, because no broker is left to answer it.

§Errors

Returns a consumer startup error, or source loss during startup, before starting the measured load.