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_discv5_discovered

Browse Source
This commit is contained in:
darshankabariya 2025-05-28 23:17:29 +05:30
parent 11b44e3e15
commit a4675c06f6
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
waku/discovery/waku_discv5.nim
View File

@ -14,7 +14,8 @@ import ../node/peer_manager/peer_manager, ../waku_core, ../waku_enr
export protocol, waku_enr
declarePublicGauge waku_discv5_discovered, "number of nodes discovered"
declarePublicGauge waku_discv5_discovered,
"number of nodes discovered", labels = ["shard"]
declarePublicGauge waku_discv5_errors, "number of waku discv5 errors", ["type"]
logScope:
@ -231,7 +232,18 @@ proc findRandomPeers*(
elif wd.predicate.isSome():
discoveredRecords = discoveredRecords.filter(wd.predicate.get())
waku_discv5_discovered.inc(discoveredRecords.len)
# Increment metric for each discovered record's shards
for record in discoveredRecords:
let typedRecord = record.toTyped().valueOr:
# If we can't parse the record, skip it
continue
let relayShards = typedRecord.relaySharding().valueOr:
# If no relay sharding info, skip it
continue
for shardId in relayShards.shardIds:
waku_discv5_discovered.inc(labelValues = [$shardId])
return discoveredRecords