From 7d4cc96cb6396e559ca2e1608f79fe622fe0b1d5 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Fri, 19 Jul 2024 14:26:25 -0400 Subject: [PATCH] fix: summary --- cmd/storemsgcounter/execute.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index ef58b07..44437cd 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -268,15 +268,14 @@ func (app *Application) verifyHistory(ctx context.Context, runId string, storeno } } - for s, cnt := range missingInSummary { - app.metrics.RecordMissingMessages(s, "does_not_exist", cnt) - logger.Info("missing message summary", zap.Stringer("storenode", s), zap.Int("numMsgs", cnt)) - } - - for s, cnt := range unknownInSummary { - app.metrics.RecordMissingMessages(s, "unknown", cnt) - logger.Info("messages that could not be verified summary", zap.Stringer("storenode", s), zap.Int("numMsgs", cnt)) + for _, s := range storenodes { + missingCnt := missingInSummary[s.ID] + app.metrics.RecordMissingMessages(s.ID, "does_not_exist", missingCnt) + logger.Info("missing message summary", zap.Stringer("storenode", s.ID), zap.Int("numMsgs", missingCnt)) + unknownCnt := unknownInSummary[s.ID] + app.metrics.RecordMissingMessages(s.ID, "unknown", unknownCnt) + logger.Info("messages that could not be verified summary", zap.Stringer("storenode", s.ID), zap.Int("numMsgs", missingCnt)) } return nil