logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-04-24 20:53:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: add waku_rln_messages_per_shard

Browse Source
This commit is contained in:
darshankabariya 2025-06-09 22:43:22 +05:30
parent 54387c0931
commit 8f4fb49b91
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
waku/waku_rln_relay/protocol_metrics.nim
View File

@ -17,8 +17,15 @@ func generateBucketsForHistogram*(length: int): seq[float64] =
return buckets
declarePublicCounter(
waku_rln_messages_total, "number of messages published on the rln content topic"
waku_rln_messages_total, "number of messages seen by the rln relay"
)
declarePublicGauge(
waku_rln_messages_per_shard,
"number of unique messages seen, grouped by shard",
labels = ["shard"],
)
declarePublicCounter(waku_rln_spam_messages_total, "number of spam messages detected")
declarePublicCounter(
waku_rln_invalid_messages_total, "number of invalid messages detected", ["type"]

3
waku/waku_rln_relay/rln_relay.nim
View File

@ -213,6 +213,9 @@ proc validateMessage*(
# track message count for metrics
waku_rln_messages_total.inc()
let shard = msg.contentTopic
waku_rln_messages_per_shard.inc(labelValues = [$shard])
# checks if the message's timestamp is within acceptable range
let currentTime = getTime().toUnixFloat()
let messageTime = msg.timestamp.float64 / 1e9