committer metrics server

Author: nischitpra

cmd/committer.go

@@ -2,7 +2,10 @@ package cmd
 
 import (
 	"fmt"
+	"net/http"
 
+	"github.com/prometheus/client_golang/prometheus/promhttp"
+	"github.com/rs/zerolog/log"
 	"github.com/spf13/cobra"
 	"github.com/thirdweb-dev/indexer/internal/committer"
 )
@@ -16,6 +19,16 @@ var committerCmd = &cobra.Command{
 
 func RunCommitter(cmd *cobra.Command, args []string) {
 	fmt.Println("running committer")
+
+	// Start Prometheus metrics server
+	log.Info().Msg("Starting Metrics Server on port 2112")
+	go func() {
+		http.Handle("/metrics", promhttp.Handler())
+		if err := http.ListenAndServe(":2112", nil); err != nil {
+			log.Error().Err(err).Msg("Metrics server error")
+		}
+	}()
+
 	committer.Init()
 	committer.CommitStreaming()
 }