Publish flushes metrics from hedged requests every tickerDur
(s *hedgedhttp.Stats, counter prometheus.Counter)
| 32 | |
| 33 | // Publish flushes metrics from hedged requests every tickerDur |
| 34 | func Publish(s *hedgedhttp.Stats, counter prometheus.Counter) { |
| 35 | publishWithDuration(s, counter, hedgedMetricsPublishDuration) |
| 36 | } |
| 37 | |
| 38 | func publishWithDuration(s statsProvider, counter prometheus.Counter, duration time.Duration) { |
| 39 | ticker := time.NewTicker(duration) |
no test coverage detected