Added metric query filter by namespace (#38)

Author: paulobressan

operator/src/metrics.rs

@@ -137,6 +137,8 @@ pub async fn run_metrics_collector(state: Arc<State>) {
         let config = get_config();
         let mut last_execution = Utc::now();
 
+        let current_namespace = client.default_namespace();
+
         loop {
             tokio::time::sleep(config.metrics_delay).await;
 
@@ -154,10 +156,9 @@ pub async fn run_metrics_collector(state: Arc<State>) {
             last_execution = end;
 
             let query = format!(
-                "sum by (user) (avg_over_time(pgbouncer_pools_client_active_connections{{user=~\"dmtr_.*\"}}[{interval}s] @ {})) > 0",
+                "sum by (user) (avg_over_time(pgbouncer_pools_client_active_connections{{user=~\"dmtr_.*\", namespace=\"{current_namespace}\"}}[{interval}s] @ {})) > 0",
                 end.timestamp_millis() / 1000
             );
-            dbg!(&query);
 
             let response = collect_prometheus_metrics(config, query).await;
             if let Err(err) = response {