Added the cluster namesapce to handle the metrics between stage and prod

example.env

@@ -68,3 +68,4 @@ APTRUST_REMOTE_SETTINGS_AWS_SECRET_ACCESS_KEY=
 
 # Metrics push gateway url 
 PROMETHEUS_PUSH_GATEWAY=http://pushgateway:9091
+CLUSTER_NAMESPACE=test-ns

lib/config.rb

@@ -211,6 +211,7 @@ def get_subset_by_key_stem(stem)
   Metrics = Struct.new(
     "MetricsConfig",
     :push_gateway_url,
+    :cluster_namespace,
     keyword_init: true
   )
 
@@ -327,7 +328,10 @@ def self.create_config(data)
           ),
           remote: create_remote_config(data.get_subset_by_key_stem("APTRUST_REMOTE_"))
         ),
-        metrics: Metrics.new(push_gateway_url: data.get_value(key: "PROMETHEUS_PUSH_GATEWAY"))
+        metrics: Metrics.new(
+          push_gateway_url: data.get_value(key: "PROMETHEUS_PUSH_GATEWAY"),
+          cluster_namespace: data.get_value(key: "CLUSTER_NAMESPACE")
+        )
       )
     end
 

lib/metrics.rb

@@ -20,6 +20,7 @@ class MetricsProvider
     def initialize(
       status_event_repo:,
       push_gateway_url:,
+      cluster_namespace:,
       start_time:,
       end_time:,
       registry: nil
@@ -28,6 +29,7 @@ def initialize(
       @end_time = end_time
       @status_event_repo = status_event_repo
       @push_gateway_url = push_gateway_url
+      @cluster_namespace = cluster_namespace
       @registry = registry
     end
 
@@ -88,7 +90,7 @@ def set_processing_duration
 
     def gateway
       @gateway ||= Prometheus::Client::Push.new(
-        job: "DarkBlueMetric",
+        job: @cluster_namespace,
         gateway: @push_gateway_url
       )
     end

run_dark_blue.rb

@@ -223,6 +223,7 @@ def self.parse(options)
   start_time: start_time,
   end_time: end_time,
   status_event_repo: S.status_event_repo,
-  push_gateway_url: config.metrics.push_gateway_url
+  push_gateway_url: config.metrics.push_gateway_url,
+  cluster_namespace: config.metrics.cluster_namespace
 )
 metrics.set_all_metrics

test/test_metrics.rb

@@ -14,6 +14,7 @@ def setup
     @end_time = @start_time + 5
     @status_event_repo = StatusEventRepository::StatusEventInMemoryRepository.new
     @push_gateway_url = "http://fake.pushgateway"
+    @cluster_namespace = "test-ns"
 
     @registry_mock = Minitest::Mock.new
     @gauge_mock = Minitest::Mock.new
@@ -23,6 +24,7 @@ def setup
       end_time: @end_time,
       status_event_repo: @status_event_repo,
       push_gateway_url: @push_gateway_url,
+      cluster_namespace: @cluster_namespace,
       registry: @registry_mock
     )
   end