Flush statsd metrics, add namespace (#36)

Layr-Labs · May 31, 2024 · 88f6e72 · 88f6e72
2 parents d062bd6 + 6922051
commit 88f6e72
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/cmd/updater.go b/cmd/updater.go
@@ -84,6 +84,7 @@ var updaterCmd = &cobra.Command{
 		if err != nil {
 			log.Fatalln(err)
 		}
+
 		s.Incr(metrics.Counter_UpdateRuns, nil, 1)
 
 		logger, err := logger.NewLogger(&logger.LoggerConfig{
@@ -99,6 +100,9 @@ var updaterCmd = &cobra.Command{
 		if err != nil {
 			logger.Sugar().Error(err)
 		}
+		if err := s.Close(); err != nil {
+			logger.Sugar().Error("Failed to close statsd client", zap.Error(err))
+		}
 	},
 }
 

diff --git a/internal/metrics/metrics.go b/internal/metrics/metrics.go
@@ -9,7 +9,7 @@ var statsdClient *statsd.Client
 
 func InitStatsdClient(addr string) (*statsd.Client, error) {
 	var err error
-	statsdClient, err = statsd.New(addr)
+	statsdClient, err = statsd.New(addr, statsd.WithNamespace("eigenlayer_rewards_updater."))
 	return statsdClient, err
 }