Method runMetrics

pkg/shell-operator/operator.go:995–1007

runMetrics spawns two long-running metric goroutines. Both honor op.ctx and are tracked by op.wg so Shutdown waits for them to finish.

()

// runMetrics spawns two long-running metric goroutines. Both honor op.ctx and
// are tracked by op.wg so Shutdown waits for them to finish.
func (op *ShellOperator) runMetrics() {
	if op.MetricStorage == nil {
		return
	}

	op.wg.Add(1)
	go op.runLiveTicks()

	if op.TaskQueues != nil {
		op.wg.Add(1)
		go op.runQueueLengthMetric()
	}
}

func (op *ShellOperator) runLiveTicks() {
	defer op.wg.Done()