Debugging client metrics

client/client.go

@@ -113,8 +113,9 @@ func (c *Client) newGRPCClient(
 		"serverAddress": c.serverAddress,
 		"async":         async,
 	})
-
+	c.logger.Infoln("Registering events gateway metrics...")
 	err := metrics.RegisterMetrics(configPrefix, c.config)
+	c.logger.Infoln("Events gateway metrics registered.")
 	if err != nil {
 		return nil, err
 	}

config/local.yaml

@@ -20,7 +20,7 @@ client:
     timeout: 500ms
 loadtestclient:
   duration: 10s
-  threads: 10
+  threads: 1
   randSleepCeilingMs: 500
   randPropsSize: small # small, medium, large, jumbo
   prometheus:

metrics/metrics.go

@@ -23,7 +23,6 @@
 package metrics
 
 import (
-	"errors"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/spf13/viper"
 )
@@ -81,22 +80,25 @@ var (
 // it only returns an error if the metric wasn't already registered and there was an
 // actual error registering it.
 func RegisterMetrics(configPrefix string, config *viper.Viper) error {
-	collectors := []prometheus.Collector{
+
+	//collectors := []prometheus.Collector{
+	//
+	//}
+	prometheus.MustRegister(
 		ClientRequestsResponseTime,
 		ClientRequestsSuccessCounter,
 		ClientRequestsFailureCounter,
-		AsyncClientRequestsDroppedCounter,
-	}
+		AsyncClientRequestsDroppedCounter)
 
-	for _, collector := range collectors {
-		err := prometheus.Register(collector)
-		if err != nil {
-			var alreadyRegisteredError prometheus.AlreadyRegisteredError
-			if !errors.As(err, &alreadyRegisteredError) {
-				return err
-			}
-		}
-	}
+	//for _, collector := range collectors {
+	//	err := prometheus.MustRegister()
+	//	if err != nil {
+	//		var alreadyRegisteredError prometheus.AlreadyRegisteredError
+	//		if !errors.As(err, &alreadyRegisteredError) {
+	//			return err
+	//		}
+	//	}
+	//}
 
 	return nil
 }

server/config/local.yaml

@@ -28,7 +28,7 @@ pprof:
   enabled: true
   address: localhost:6060
 otlp:
-  enabled: true
+  enabled: false
   serviceName: "eventsgateway-server"
   traceSamplingRatio: 0.2
   jaegerHost: jaeger