logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-09 17:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: add shard to waku_archive_messages

Browse Source
This commit is contained in:
darshankabariya 2025-05-29 02:03:45 +05:30
parent a4675c06f6
commit fbfad1ff60
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
waku/waku_archive/archive.nim
View File

@ -119,6 +119,11 @@ proc handleMessage*(
let insertDuration = getTime().toUnixFloat() - insertStartTime
waku_archive_insert_duration_seconds.observe(insertDuration)
let shard = RelayShard.parseStaticSharding(pubsubTopic).valueOr:
DefaultRelayShard
waku_archive_messages.inc(labelValues = ["stored", $shard.shardId])
trace "message archived",
msg_hash = msgHashHex,
pubsubTopic = pubsubTopic,
@ -267,9 +272,6 @@ proc periodicMetricReport(self: WakuArchive) {.async.} =
if countRes.isErr():
error "loopReportStoredMessagesMetric failed to get messages count",
error = countRes.error
else:
let count = countRes.get()
waku_archive_messages.set(count, labelValues = ["stored"])
await sleepAsync(WakuArchiveDefaultMetricsReportInterval)

3
waku/waku_archive/archive_metrics.nim
View File

@ -2,7 +2,8 @@
import metrics
declarePublicGauge waku_archive_messages, "number of historical messages", ["type"]
declarePublicGauge waku_archive_messages,
"number of historical messages", ["type", "shard"]
declarePublicGauge waku_archive_errors, "number of store protocol errors", ["type"]
declarePublicGauge waku_archive_queries, "number of store queries received"
declarePublicHistogram waku_archive_insert_duration_seconds,