Function BenchmarkWorkerPool

pkg/workerpool/workerpool_test.go:277–291

(b *testing.B)

}

func BenchmarkWorkerPool(b *testing.B) {
	delays := []time.Duration{5 * time.Millisecond, 10 * time.Millisecond, 50 * time.Millisecond}
	for _, processingDelay := range delays {
		for _, publishingDelay := range delays {
			name := fmt.Sprintf(
				"processingDelay/%v/publishingDelay/%v",
				processingDelay,
				publishingDelay,
			)
			b.Run(name, func(b *testing.B) {
				benchmarkWorkerPool(b, processingDelay, publishingDelay)
			})
		}
	}
}