Method ShouldUpdate

modules/distributor/queue/queue.go:131–133

ShouldUpdate returns true if the queue size or worker count (alive or total) has changed

(size, workerCount int)

// ShouldUpdate returns true if the queue size or worker count (alive or total) has changed
func (m *Queue[T]) ShouldUpdate(size, workerCount int) bool {
	return m.size != size || m.workerCount != workerCount
}

func (m *Queue[T]) Shutdown(ctx context.Context) error {
	// Call to stopWorkers only once