total

Layr-Labs · Mar 8, 2024 · 8ed0afd · 8ed0afd
1 parent 3bd7b47
commit 8ed0afd
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 29 deletions.
diff --git a/disperser/apiserver/server.go b/disperser/apiserver/server.go
@@ -90,8 +90,6 @@ func NewDispersalServer(
 }
 
 func (s *DispersalServer) DisperseBlobAuthenticated(stream pb.Disperser_DisperseBlobAuthenticatedServer) error {
-	s.metrics.IncrementBlobRequestNum("DisperseBlobAuthenticated")
-
 	// Process disperse_request
 	in, err := stream.Recv()
 	if err != nil {
@@ -170,8 +168,6 @@ func (s *DispersalServer) DisperseBlobAuthenticated(stream pb.Disperser_Disperse
 }
 
 func (s *DispersalServer) DisperseBlob(ctx context.Context, req *pb.DisperseBlobRequest) (*pb.DisperseBlobReply, error) {
-	s.metrics.IncrementBlobRequestNum("DisperseBlob")
-
 	blob := getBlobFromRequest(req)
 
 	reply, err := s.disperseBlob(ctx, blob, "")
@@ -444,8 +440,6 @@ func (s *DispersalServer) GetBlobStatus(ctx context.Context, req *pb.BlobStatusR
 	}))
 	defer timer.ObserveDuration()
 
-	s.metrics.IncrementBlobRequestNum("GetBlobStatus")
-
 	requestID := req.GetRequestId()
 	if len(requestID) == 0 {
 		return nil, api.NewInvalidArgError("request_id must not be empty")
@@ -548,8 +542,6 @@ func (s *DispersalServer) RetrieveBlob(ctx context.Context, req *pb.RetrieveBlob
 	}))
 	defer timer.ObserveDuration()
 
-	s.metrics.IncrementBlobRequestNum("RetrieveBlob")
-
 	s.logger.Info("received a new blob retrieval request", "batchHeaderHash", req.BatchHeaderHash, "blobIndex", req.BlobIndex)
 
 	batchHeaderHash := req.GetBatchHeaderHash()

diff --git a/disperser/metrics.go b/disperser/metrics.go
@@ -99,16 +99,6 @@ func (g *Metrics) HandleSuccessfulRequest(quorum string, blobBytes int, method s
 	}).Add(float64(blobBytes))
 }
 
-// IncrementBlobRequestNum increments the number of blob requests received
-func (g *Metrics) IncrementBlobRequestNum(method string) {
-	g.NumBlobRequests.With(prometheus.Labels{
-		"status_code": "total",
-		"status":      "total",
-		"quorum":      "",
-		"method":      method,
-	}).Inc()
-}
-
 // IncrementFailedBlobRequestNum increments the number of failed blob requests
 func (g *Metrics) IncrementFailedBlobRequestNum(statusCode string, quorum string, method string) {
 	g.NumBlobRequests.With(prometheus.Labels{

diff --git a/operators/churner/metrics.go b/operators/churner/metrics.go
@@ -89,15 +89,6 @@ func (g *Metrics) ObserveLatency(method string, latencyMs float64) {
 	g.Latency.WithLabelValues(method).Observe(latencyMs)
 }
 
-// IncrementRequestNum increments the number of successful requests
-func (g *Metrics) IncrementRequestNum(method string) {
-	g.NumRequests.With(prometheus.Labels{
-		"status": "total",
-		"method": method,
-		"reason": "",
-	}).Inc()
-}
-
 // IncrementSuccessfulRequestNum increments the number of successful requests
 func (g *Metrics) IncrementSuccessfulRequestNum(method string) {
 	g.NumRequests.With(prometheus.Labels{

diff --git a/operators/churner/server.go b/operators/churner/server.go
@@ -55,8 +55,6 @@ func (s *Server) Start(metricsConfig MetricsConfig) error {
 }
 
 func (s *Server) Churn(ctx context.Context, req *pb.ChurnRequest) (*pb.ChurnReply, error) {
-	s.metrics.IncrementRequestNum("Churn")
-
 	err := s.validateChurnRequest(ctx, req)
 	if err != nil {
 		s.metrics.IncrementFailedRequestNum("Churn", FailReasonInvalidRequest)