je_load_density.utils.metrics.statsd_sink

Datadog DogStatsD UDP sink.

Listens to Locust request events and emits StatsD packets in the Datadog dialect:

• loaddensity.requests:1|c|#method:get,name:/x,outcome:success

• loaddensity.request.latency:42|ms|#method:get,name:/x

• loaddensity.response.size:1024|h|#method:get,name:/x

Pure UDP socket; no datadog SDK required.

Functions

format_packets(prefix, method, name, ...)
start_statsd_sink([host, port, prefix])	Subscribe to Locust request events and emit DogStatsD packets over UDP.
stop_statsd_sink()

je_load_density.utils.metrics.statsd_sink.format_packets(prefix: str, method: str, name: str, response_time_ms: float | None, response_length: int | None, outcome: str) → List[str]

je_load_density.utils.metrics.statsd_sink.start_statsd_sink(host: str = '127.0.0.1', port: int = 8125, prefix: str = 'loaddensity') → _StatsdEmitter

Subscribe to Locust request events and emit DogStatsD packets over UDP. Idempotent — calling twice rebinds.

je_load_density.utils.metrics.statsd_sink.stop_statsd_sink() → None