Versions in this module Expand all Collapse all v0 v0.12.0 Jan 21, 2020 Changes in this version + func NewSender(loadGeneratorFactory LoadGeneratorFactory, aggregAddr string, msgSize uint, ...) (common.Executor, error) + type CloudEventsTargeter struct + func NewCloudEventsTargeter(sinkUrl string, msgSize uint, eventType string, eventSource string) CloudEventsTargeter + func (cet CloudEventsTargeter) VegetaTargeter() vegeta.Targeter + type HttpLoadGenerator struct + func (h HttpLoadGenerator) RunPace(i int, pace common.PaceSpec, msgSize uint) + func (h HttpLoadGenerator) SendEndEvent() + func (h HttpLoadGenerator) SendGCEvent() + func (h HttpLoadGenerator) Warmup(pace common.PaceSpec, msgSize uint) + type LoadGenerator interface + RunPace func(i int, pace common.PaceSpec, msgSize uint) + SendEndEvent func() + SendGCEvent func() + Warmup func(pace common.PaceSpec, msgSize uint) + type LoadGeneratorFactory func(eventSource string, sentCh chan common.EventTimestamp, ...) (LoadGenerator, error) + func NewHttpLoadGeneratorFactory(sinkUrl string, minWorkers uint64) LoadGeneratorFactory + type Sender struct + func (s *Sender) Run(ctx context.Context)
Go to main page