Method shutdownQueueList

modules/distributor/forwarder/manager.go:205–209

(tenantID string, ql *queueList)

}

func (m *Manager) shutdownQueueList(tenantID string, ql *queueList) {
	if err := ql.shutdown(context.Background()); err != nil {
		_ = level.Warn(m.logger).Log("msg", "failed to shutdown queue list", "tenantID", tenantID)
	}
}

type queueList struct {
	logger               log.Logger