()
| 1007 | } |
| 1008 | |
| 1009 | func (op *ShellOperator) runLiveTicks() { |
| 1010 | defer op.wg.Done() |
| 1011 | ticker := time.NewTicker(10 * time.Second) |
| 1012 | defer ticker.Stop() |
| 1013 | // Emit one tick immediately so the metric appears before the first interval. |
| 1014 | op.MetricStorage.CounterAdd(metrics.LiveTicks, 1.0, map[string]string{}) |
| 1015 | for { |
| 1016 | select { |
| 1017 | case <-op.ctx.Done(): |
| 1018 | return |
| 1019 | case <-ticker.C: |
| 1020 | op.MetricStorage.CounterAdd(metrics.LiveTicks, 1.0, map[string]string{}) |
| 1021 | } |
| 1022 | } |
| 1023 | } |
| 1024 | |
| 1025 | func (op *ShellOperator) runQueueLengthMetric() { |
| 1026 | defer op.wg.Done() |
no test coverage detected