@@ -32,8 +32,8 @@ when defined(libp2p_expensive_metrics):
3232 declareCounter (libp2p_pubsub_skipped_received_messages, " number of received skipped messages" , labels = [" id" ])
3333 declareCounter (libp2p_pubsub_skipped_sent_messages, " number of sent skipped messages" , labels = [" id" ])
3434
35- declareGauge (libp2p_gossipsub_priority_queue_size, " the number of messages in the priority queue" , labels = [" id" ])
36- declareGauge (libp2p_gossipsub_non_priority_queue_size, " the number of messages in the non-priority queue" , labels = [" id" ])
35+ declareGauge (libp2p_gossipsub_priority_queue_size, " the number of messages in the priority queue" , labels = [" id" ])
36+ declareGauge (libp2p_gossipsub_non_priority_queue_size, " the number of messages in the non-priority queue" , labels = [" id" ])
3737
3838type
3939 PeerRateLimitError * = object of CatchableError
@@ -390,8 +390,9 @@ proc stopSendNonPriorityTask*(p: PubSubPeer) =
390390 p.rpcmessagequeue.sendNonPriorityTask = nil
391391 p.rpcmessagequeue.sendPriorityQueue.clear ()
392392 p.rpcmessagequeue.nonPriorityQueue.clear ()
393- libp2p_gossipsub_priority_queue_size.set (labelValues = [$ p.peerId], value = 0 )
394- libp2p_gossipsub_non_priority_queue_size.set (labelValues = [$ p.peerId], value = 0 )
393+ when defined (libp2p_expensive_metrics):
394+ libp2p_gossipsub_priority_queue_size.set (labelValues = [$ p.peerId], value = 0 )
395+ libp2p_gossipsub_non_priority_queue_size.set (labelValues = [$ p.peerId], value = 0 )
395396
396397proc new (T: typedesc [RpcMessageQueue ]): T =
397398 return T (
0 commit comments