chore: making metrics name consistent

WalletConnect · Nov 13, 2023 · 5e96f88 · 5e96f88
1 parent 9ccdb82
commit 5e96f88
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 13 deletions.
diff --git a/src/metrics.rs b/src/metrics.rs
@@ -35,8 +35,8 @@ pub struct Metrics {
     pub processed_notifications: Counter<u64>,
     pub dispatched_notifications: Counter<u64>,
     pub notify_latency: Histogram<u64>,
-    pub spawned_publishing_workers: ObservableGauge<u64>,
-    pub publishing_worker_errors: Counter<u64>,
+    pub publishing_workers_count: ObservableGauge<u64>,
+    pub publishing_workers_errors: Counter<u64>,
 }
 
 impl Metrics {
@@ -115,13 +115,13 @@ impl Metrics {
             .with_description("The amount of time it took to dispatch all notifications")
             .init();
 
-        let spawned_publishing_workers = meter
-            .u64_observable_gauge("spawned_publishing_workers")
+        let publishing_workers_count = meter
+            .u64_observable_gauge("publishing_workers_count")
             .with_description("The number of spawned publishing workers tasks")
             .init();
 
-        let publishing_worker_errors = meter
-            .u64_counter("publishing_worker_errors")
+        let publishing_workers_errors = meter
+            .u64_counter("publishing_workers_errors")
             .with_description("The number of publishing worker that ended with an error")
             .init();
 
@@ -140,8 +140,8 @@ impl Metrics {
             processed_notifications,
             dispatched_notifications,
             notify_latency,
-            spawned_publishing_workers,
-            publishing_worker_errors,
+            publishing_workers_count,
+            publishing_workers_errors,
         }
     }
 }

diff --git a/src/services/publisher_service/mod.rs b/src/services/publisher_service/mod.rs
@@ -119,7 +119,7 @@ async fn process_and_handle(
 
     let ctx = Context::current();
     if let Some(metrics) = metrics {
-        metrics.spawned_publishing_workers.observe(
+        metrics.publishing_workers_count.observe(
             &ctx,
             spawned_tasks_counter.load(Ordering::SeqCst) as u64,
             &[],
@@ -129,15 +129,15 @@ async fn process_and_handle(
 
     if let Err(e) = process_queued_messages(postgres, relay_http_client, metrics, analytics).await {
         if let Some(metrics) = metrics {
-            metrics.publishing_worker_errors.add(&ctx, 1, &[]);
+            metrics.publishing_workers_errors.add(&ctx, 1, &[]);
         }
         warn!("Error on processing queued messages by the worker: {:?}", e);
     }
 
     spawned_tasks_counter.fetch_sub(1, Ordering::SeqCst);
 
     if let Some(metrics) = metrics {
-        metrics.spawned_publishing_workers.observe(
+        metrics.publishing_workers_count.observe(
             &ctx,
             spawned_tasks_counter.load(Ordering::SeqCst) as u64,
             &[],

diff --git a/terraform/monitoring/panels/app/publishing_workers_count.libsonnet b/terraform/monitoring/panels/app/publishing_workers_count.libsonnet
@@ -13,7 +13,7 @@ local targets   = grafana.targets;
     .configure(defaults.configuration.timeseries)
     .addTarget(targets.prometheus(
       datasource  = ds.prometheus,
-      expr        = 'sum(rate(spawned_publishing_workers_total{}[$__rate_interval]))',
+      expr        = 'sum(rate(publishing_workers_count_total{}[$__rate_interval]))',
       refId       = "availability",
     ))
 }
diff --git a/terraform/monitoring/panels/app/publishing_workers_errors.libsonnet b/terraform/monitoring/panels/app/publishing_workers_errors.libsonnet
@@ -13,7 +13,7 @@ local targets   = grafana.targets;
     .configure(defaults.configuration.timeseries)
     .addTarget(targets.prometheus(
       datasource  = ds.prometheus,
-      expr        = 'sum(rate(publishing_worker_errors_total{}[$__rate_interval]))',
+      expr        = 'sum(rate(publishing_workers_errors_total{}[$__rate_interval]))',
       refId       = "availability",
     ))
 }