Method StartWorkers

modules/distributor/queue/queue.go:107–113

()

}

func (m *Queue[T]) StartWorkers() {
	for i := 0; i < m.workerCount; i++ {
		m.wg.Add(1)

		go m.worker()
	}
}

// TenantID returns the tenant id.
func (m *Queue[T]) TenantID() string {