Method startMetricsMonitoring

pkg/task/queue/task_queue.go:693–714

startMetricsMonitoring starts a goroutine that periodically updates compaction metrics by taking a snapshot of the queue and counting tasks per hook.

()

// startMetricsMonitoring starts a goroutine that periodically updates compaction metrics
// by taking a snapshot of the queue and counting tasks per hook.
func (q *TaskQueue) startMetricsMonitoring() {
	if q.metricStorage == nil || q.queueTasksCounter == nil {
		return
	}

	go func() {
		// Update metrics immediately on start
		q.updateCompactionMetrics()

		ticker := time.NewTicker(metricsMonitoringUpdateInterval)
		defer ticker.Stop()

		for {
			select {
			case <-q.ctx.Done():
				return
			case <-ticker.C:
				q.updateCompactionMetrics()
			}
		}
	}()
}

// updateCompactionMetrics counts tasks by hook and updates metrics
func (q *TaskQueue) updateCompactionMetrics() {