Module driver 

Shared DogStatsD load-driver engine.

A producer thread samples lines into a bounded channel; a consumer thread fans each line out to every socket and tallies per-socket sends. Drivers differ only in how many sockets they target and which anchors they fire, so both the single-socket and differential drivers run on this one engine.

Structs

Stats

What a driver run shipped, for anchoring assertions.

Enums

Batch

Per-batch composition: 50% clean, 25% feral, 25% mixed.

Functions

connect_with_retry

Wait for the remote process to bind path, intentionally naive. Returns None if the socket is still unavailable after 30 seconds.

run

Drive one batch of sampled DogStatsD lines to every socket.