From: bravof <fbravo@whitestack.com>
Date: Mon, 10 May 2021 15:05:20 +0000 (-0400)
Subject: feat(prometheus): store mon job into prometheus collection, part of the decoupling... 
X-Git-Tag: release-v10.0-start
X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=19039088f41361c813c0e1069d4f4e6790ca3f41;p=osm%2FMON.git

feat(prometheus): store mon job into prometheus collection, part of the decoupling between LCM and Prometheus

Change-Id: I5a547729a0c51a13cffb6a8467788992b574c0e9
Signed-off-by: bravof <fbravo@whitestack.com>
---

diff --git a/osm_mon/server/server.py b/osm_mon/server/server.py
index ce6255c..07fdd22 100755
--- a/osm_mon/server/server.py
+++ b/osm_mon/server/server.py
@@ -43,6 +43,7 @@ class Server:
         self.loop = loop
         self.msg_bus = MessageBusClient(config)
         self.service = ServerService(config)
+        self.service.populate_prometheus()
 
     def run(self):
         self.loop.run_until_complete(self.start())
diff --git a/osm_mon/server/service.py b/osm_mon/server/service.py
index 298043e..94bdf4e 100755
--- a/osm_mon/server/service.py
+++ b/osm_mon/server/service.py
@@ -55,3 +55,21 @@ class ServerService:
         log.debug("delete_alarm")
         self.common_db.delete_alarm(alarm_uuid)
         log.info("Alarm %s is deleted", alarm_uuid)
+
+    def populate_prometheus(self):
+        # This method can be executed infinite number of times
+        # without side-effects.
+        self.common_db.common_db.set_one(
+            "prometheus_jobs", {"job_name": "mon_exporter"}, {
+                "job_name": "mon_exporter",
+                "static_configs": [
+                    {
+                        "targets": [
+                            "mon:8000"
+                        ]
+                    }
+                ]
+            },
+            fail_on_empty=False,
+            upsert=True
+        )