in cmd/apmtelemetrygen/main.go [167:189]
func (opts *runOptions) toEventHandlerParams(logger *zap.Logger) (loadgen.EventHandlerParams, error) {
burst, interval, err := loadgen.ParseEventRate(opts.EventRate)
if err != nil {
return loadgen.EventHandlerParams{}, err
}
return loadgen.EventHandlerParams{
Logger: logger,
Path: "apm*.ndjson",
URL: opts.ServerURL,
Token: opts.SecretToken,
APIKey: opts.APIKey,
Headers: opts.Headers,
IgnoreErrors: opts.IgnoreErrors,
Protocol: opts.Protocol,
Datatype: opts.Datatype,
Limiter: loadgen.GetNewLimiter(burst, interval),
Rand: rand.New(rand.NewSource(time.Now().UnixNano())),
RewriteIDs: opts.RewriteIDs,
RewriteTimestamps: opts.RewriteTimestamps,
}, nil
}