From 70180fa39e3d21feea0ef9df6f0edd0917cafa59 Mon Sep 17 00:00:00 2001 From: mphanias Date: Thu, 23 Nov 2023 16:51:43 +0530 Subject: [PATCH] OM86 --- watcher_latency.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/watcher_latency.go b/watcher_latency.go index 59cd9bee..76b5aa18 100644 --- a/watcher_latency.go +++ b/watcher_latency.go @@ -60,6 +60,18 @@ func (lw *LatencyWatcher) refresh(o *Observer, infoKeys []string, rawMetrics map } } + // loop all the latency infokeys + for ik := range infoKeys { + parseSingleLatenciesKey(infoKeys[ik], rawMetrics, allowedLatenciesList, blockedLatenciessList, ch) + } + + return nil +} + +func parseSingleLatenciesKey(singleLatencyKey string, rawMetrics map[string]string, + allowedLatenciesList map[string]struct{}, + blockedLatenciessList map[string]struct{}, ch chan<- prometheus.Metric) error { + var latencyStats map[string]StatsMap if rawMetrics["latencies:"] != "" {