Module workload 

Producer and consumer workload runners.

This module builds N producers and M consumers as members of one group, runs the warmup phase and then the measurement phase, triggers an optional failover mid-measurement, and merges the per-task histograms into the public LatencyPercentiles shape.

Structs

ClientIdentity

The PEM files of an mTLS client identity.

ConsumerBuildAttempts

How many times the driver tries to build a consumer before it gives up.

ConsumerBuildRetryPolicy

DriverConfig

Parameters wired in from main and the CLI. This struct is distinct from Scenario because the scenario YAML describes what to run, and this struct describes where it runs.

TlsParams

TLS knobs for the producer and consumer data path.

Constants

DEFAULT_CONSUMER_BUILD_ATTEMPTS

DEFAULT_CONSUMER_BUILD_INITIAL_BACKOFF

DEFAULT_CONSUMER_BUILD_MAX_BACKOFF

DEFAULT_CONSUMER_POLL_ERROR_BACKOFF

DEFAULT_CONSUMER_POLL_TIMEOUT

DEFAULT_KAFKA_CONSUMER_REQUEST_TIMEOUT

DEFAULT_KRABKA_CONSUMER_REQUEST_TIMEOUT

DEFAULT_PRODUCER_FINAL_DRAIN_TIMEOUT

DEFAULT_PRODUCER_REQUEST_TIMEOUT

DEFAULT_SAMPLE_INTERVAL

MAX_CLIENT_REQUEST_TIMEOUT

Functions

default_consumer_build_initial_backoff

default_consumer_build_max_backoff

default_consumer_poll_error_backoff

default_consumer_poll_timeout

default_consumer_request_timeout

Return the validated consumer request-timeout default for stack.

default_producer_request_timeout

Return the validated producer request-timeout default.

run

Top-level entry point that main calls. Returns the populated RunOutput. The caller must serialise it to disk.