Init prometheus registry in main.go

avssync/avssync.go

@@ -45,9 +45,9 @@ func NewAvsSync(
 	quorums []byte, fetchQuorumsDynamically bool, retrySyncNTimes int,
 	readerTimeoutDuration time.Duration, writerTimeoutDuration time.Duration,
 	prometheusServerAddr string,
+	prometheusRegistry *prometheus.Registry,
 ) *AvsSync {
-	promReg := prometheus.NewRegistry()
-	metrics := NewMetrics(promReg)
+	metrics := NewMetrics(prometheusRegistry, prometheusServerAddr)
 
 	return &AvsSync{
 		AvsReader:                    avsReader,

avssync/metrics.go

@@ -44,6 +44,8 @@ func NewMetrics(reg *prometheus.Registry) *Metrics {
 			Name:      "operators_updated",
 			Help:      "The total number of operators updated (during the last quorum sync)",
 		}, []string{"quorum"}),
+
+		registry: reg,
 	}
 
 	return metrics

integration_test.go

@@ -15,6 +15,7 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 	gethtypes "github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/prometheus/client_golang/prometheus"
 	"github.com/testcontainers/testcontainers-go"
 	"github.com/testcontainers/testcontainers-go/wait"
 	"go.uber.org/mock/gomock"
@@ -274,6 +275,7 @@ func NewAvsSyncComponents(t *testing.T, anvilHttpEndpoint string, contractAddres
 		time.Second,
 		time.Second,
 		"", // no metrics server (otherwise parallel tests all try to start server at same endpoint and error out)
+		prometheus.NewRegistry(),
 	)
 	return &AvsSyncComponents{
 		avsSync:   avsSync,

main.go

@@ -19,6 +19,7 @@ import (
 	"github.com/Layr-Labs/eigensdk-go/signerv2"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/prometheus/client_golang/prometheus"
 	"github.com/urfave/cli"
 )
 
@@ -208,6 +209,10 @@ func avsSyncMain(cliCtx *cli.Context) error {
 		sleepBeforeFirstSyncDuration = firstSyncTime.Sub(now)
 	}
 	logger.Infof("Sleeping for %v before first sync, so that it happens at %v", sleepBeforeFirstSyncDuration, time.Now().Add(sleepBeforeFirstSyncDuration))
+
+	// Create new prometheus registry
+	reg := prometheus.NewRegistry()
+
 	avsSync := avssync.NewAvsSync(
 		logger,
 		avsReader,
@@ -221,6 +226,7 @@ func avsSyncMain(cliCtx *cli.Context) error {
 		readerTimeout,
 		writerTimeout,
 		cliCtx.String(MetricsAddrFlag.Name),
+		reg,
 	)
 
 	avsSync.Start(context.Background())