Track gossipValidationQueueConcurrency

ChainSafe · Feb 28, 2023 · 99cb497 · 99cb497
1 parent 319a24e
commit 99cb497
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/packages/beacon-node/src/metrics/metrics/lodestar.ts b/packages/beacon-node/src/metrics/metrics/lodestar.ts
@@ -267,7 +267,7 @@ export function createLodestarMetrics(
     }),
     gossipValidationQueueConcurrency: register.gauge<"topic">({
       name: "lodestar_gossip_validation_queue_concurrency",
-      help: "Current concurrency of gossip validation queue",
+      help: "Current count of jobs being run on network processor for topic",
       labelNames: ["topic"],
     }),
 

diff --git a/packages/beacon-node/src/network/processor/index.ts b/packages/beacon-node/src/network/processor/index.ts
@@ -76,6 +76,7 @@ export class NetworkProcessor {
       metrics.gossipValidationQueueLength.addCollect(() => {
         for (const topic of executeGossipWorkOrder) {
           metrics.gossipValidationQueueLength.set({topic}, this.gossipQueues[topic].length);
+          metrics.gossipValidationQueueConcurrency.set({topic}, this.gossipTopicConcurrency[topic]);
         }
       });
     }