Method updateCompactionMetrics

pkg/task/queue/task_queue.go:717–745

updateCompactionMetrics counts tasks by hook and updates metrics

()

// updateCompactionMetrics counts tasks by hook and updates metrics
func (q *TaskQueue) updateCompactionMetrics() {
	hookCounts := make(map[string]uint)

	// Use IterateSnapshot to avoid holding locks during iteration
	q.IterateSnapshot(func(t task.Task) {
		// Only count compactable task types
		if _, ok := q.compactableTypes[t.GetType()]; !ok {
			return
		}

		metadata := t.GetMetadata()
		if isNil(metadata) {
			return
		}

		hookNameAccessor, ok := metadata.(task_metadata.HookNameAccessor)
		if !ok {
			return
		}

		hookName := hookNameAccessor.GetHookName()
		if hookName != "" {
			hookCounts[hookName]++
		}
	})

	// Update metrics based on current state
	q.queueTasksCounter.UpdateHookMetricsFromSnapshot(hookCounts)
}

// lazydebug evaluates args only if debug log is enabled.
// It is used to avoid unnecessary allocations when logging is disabled.