func()

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
}