Function NewRunner

_benchmarks/benchmarks/runner/runner.go:56–82

NewRunner returns new benchmarking runner.

(cfg Config)

// NewRunner returns new benchmarking runner.
func NewRunner(cfg Config) (*Runner, error) {
	if err := validateConfig(cfg); err != nil {
		return nil, err
	}

	if cfg.NumOperations == 0 {
		cfg.NumOperations = 1
	}

	indexer, err := esutil.NewBulkIndexer(
		esutil.BulkIndexerConfig{
			Client:        cfg.ReportClient,
			Index:         statsIndex,
			FlushBytes:    2e+6,
			FlushInterval: 15 * time.Second,
			OnError:       func(ctx context.Context, err error) { errs = append(errs, err) },
		},
	)
	if err != nil {
		return nil, fmt.Errorf("cannot create bulk indexer: %w", err)
	}

	return &Runner{
		config:  cfg,
		indexer: indexer,
	}, nil
}

// Runner represents the benchmarking runner.
type Runner struct {