Skip to main content

prepare

Function prepare 

Source
pub async fn prepare(
    contract: &Contract,
    endpoint: &Endpoint,
) -> Result<PreparedLoad, ConsumerError>
Expand description

Join every consumer group before starting the measured load and its fault clock, so coordinator startup does not age the first produced records.

ยงErrors

Returns a consumer startup error before any producer starts.