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
}