Function newStartedQueue

modules/distributor/queue/queue_test.go:37–42

(t *testing.T, size, workerCount int, processFunc ProcessFunc[T])

}

func newStartedQueue[T any](t *testing.T, size, workerCount int, processFunc ProcessFunc[T]) *Queue[T] {
	q := newQueue(t, size, workerCount, processFunc)
	q.StartWorkers()

	return q
}

func getCounterValue(metric *prometheus.CounterVec) float64 {
	m := &dto.Metric{}