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

chore: lint update

Browse Source
This commit is contained in:
darshankabariya 2025-06-10 00:20:36 +05:30
parent 8f4fb49b91
commit 8d80fd282a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
waku/node/peer_manager/peer_manager.nim
View File

@ -35,8 +35,7 @@ declarePublicGauge waku_connected_peers,
"Number of physical connections per direction and protocol",
labels = ["direction", "protocol"]
declarePublicGauge waku_connected_peers_per_shard,
"Number of physical connections per shard",
labels = ["shard"]
"Number of physical connections per shard", labels = ["shard"]
declarePublicGauge waku_streams_peers,
"Number of streams per direction and protocol", labels = ["direction", "protocol"]
declarePublicGauge waku_peer_store_size, "Number of peers managed by the peer store"
@ -812,11 +811,12 @@ proc logAndMetrics(pm: PeerManager) {.async.} =
protoStreamsOut.float64, labelValues = [$Direction.Out, proto]
)
for shard in 0..63: # Assuming shards are 0-63 as per Waku spec
for shard in 0 .. 63: # Assuming shards are 0-63 as per Waku spec
waku_connected_peers_per_shard.set(0.0, labelValues = [$shard])
for shard in pm.wakuMetadata.shards.items:
let connectedPeers = peerStore.getPeersByShard(uint16(pm.wakuMetadata.clusterId), uint16(shard))
let connectedPeers =
peerStore.getPeersByShard(uint16(pm.wakuMetadata.clusterId), uint16(shard))
waku_connected_peers_per_shard.set(
connectedPeers.len.float64, labelValues = [$shard]
)