logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-02 14:13:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: summary

Browse Source
This commit is contained in:
Richard Ramos 2024-07-19 14:26:25 -04:00
parent 3b1df25ddf
commit 7d4cc96cb6
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cmd/storemsgcounter/execute.go
View File

@ -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