Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateMessage ¶
Types ¶
type Scenario ¶
type Scenario struct {
Name string
Duration time.Duration
NumPartitions int // explicit partition count; 0 = use Producers
Producers int
Consumers int
MsgSize int // bytes per message
RatePerSec int // target messages/second per producer
BurstEvery time.Duration // inject burst at this interval (0 = no bursts)
BurstFactor int // burst multiplier
SkewRatio float64 // fraction of messages using a fixed hot key (0 = uniform)
Priorities [10]float64 // probability distribution over priority levels
Seed int64 // RNG seed for deterministic replay; default 42
BatchBytes int // target batch size in bytes (0 = default 16KB)
LingerMs int // batch linger in ms for rate-limited producers (0 = default 1)
ConsumerSkewRate float64 // heterogeneous consumer speed: slowest consumer relative speed [0,1]; 0 = uniform
}
func GrowingLoad ¶
func GrowingLoad() Scenario
func MixedPriority ¶
func MixedPriority() Scenario
func OverloadK16 ¶
func OverloadK16() Scenario
func OverloadK32 ¶
func OverloadK32() Scenario
func (*Scenario) SamplePriority ¶
Source Files
Click to show internal directories.
Click to hide internal directories.