using index_label method on pipeline counter

Author: fulmicoton-dd

quickwit/quickwit-common/src/metrics.rs

@@ -220,10 +220,7 @@ impl std::fmt::Debug for GaugeGuard<'_> {
 
 impl<'a> GaugeGuard<'a> {
     pub fn from_gauge_with_initial_value(gauge: &'a IntGauge, initial_value: i64) -> Self {
-        let mut gauge = Self {
-            gauge,
-            delta: initial_value,
-        };
+        let mut gauge = Self { gauge, delta: 0i64 };
         gauge.add(initial_value);
         gauge
     }

quickwit/quickwit-indexing/src/actors/indexing_pipeline.rs

@@ -158,7 +158,9 @@ impl IndexingPipeline {
     pub fn new(params: IndexingPipelineParams) -> Self {
         let indexing_pipelines_gauge = crate::metrics::INDEXER_METRICS
             .indexing_pipelines
-            .with_label_values([&params.pipeline_id.index_uid.index_id]);
+            .with_label_values([&quickwit_common::metrics::index_label(
+                &params.pipeline_id.index_uid.index_id,
+            )]);
         let indexing_pipelines_gauge_guard =
             OwnedGaugeGuard::from_gauge_with_initial_value(indexing_pipelines_gauge, 1);
         let params_fingerprint = params.params_fingerprint;

quickwit/quickwit-metastore/src/metastore/postgres/pool.rs

@@ -59,9 +59,7 @@ impl<'a, DB: Database> Acquire<'a> for &TrackedPool<DB> {
             .set(self.inner_pool.num_idle() as i64);
 
         Box::pin(async move {
-            let mut gauge_guard = GaugeGuard::from_gauge(&POSTGRES_METRICS.acquire_connections);
-            gauge_guard.add(1);
-
+            let gauge_guard = GaugeGuard::from_gauge_with_initial_value(&POSTGRES_METRICS.acquire_connections, 1);
             let conn = acquire_conn_fut.await?;
             Ok(conn)
         })