(BIDS-3222) serve metrics in notif collector/sender (#2916)

gobitfly · Jul 25, 2024 · 1354142 · 1354142
1 parent dba0c62
commit 1354142
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/cmd/notification-collector/main.go b/cmd/notification-collector/main.go
@@ -162,6 +162,13 @@ func main() {
 		if DBStr != frontendDBStr {
 			go metrics.MonitorDB(db.FrontendWriterDB)
 		}
+		// serve prometheus metrics
+		go func(addr string) {
+			logrus.Infof("serving metrics on %v", addr)
+			if err := metrics.Serve(addr); err != nil {
+				logrus.WithError(err).Fatal("Error serving metrics")
+			}
+		}(utils.Config.Metrics.Address)
 	}
 
 	logrus.Infof("database connection established")

diff --git a/cmd/notification-sender/main.go b/cmd/notification-sender/main.go
@@ -159,6 +159,13 @@ func main() {
 		if DBStr != frontendDBStr {
 			go metrics.MonitorDB(db.FrontendWriterDB)
 		}
+		// serve prometheus metrics
+		go func(addr string) {
+			logrus.Infof("serving metrics on %v", addr)
+			if err := metrics.Serve(addr); err != nil {
+				logrus.WithError(err).Fatal("Error serving metrics")
+			}
+		}(utils.Config.Metrics.Address)
 	}
 
 	logrus.Infof("database connection established")