func loadTestThroughput()

in tester/run/throughput.go [69:94]


func loadTestThroughput(r tester.ThroughputRunner, t tester.Tester, o interface{}, qps tester.QPS) error {
	if err := t.BeforeEach(o); err != nil {
		//nolint:wrapcheck
		return err
	}

	defer t.AfterEach(o)

	if err := r.Before(qps, o); err != nil {
		//nolint:wrapcheck
		return err
	}

	defer r.After(qps, o)

	executor, err := t.RequestExecutor(o)
	if err != nil {
		//nolint:wrapcheck
		return err
	}

	bender.LoadTestThroughput(r.Intervals(), r.Requests(), executor, r.Recorder())
	bender.Record(r.Recorder(), r.Recorders()...)

	return nil
}