fix: metrics

ethersphere · Sep 23, 2023 · 78e8e17 · 78e8e17
1 parent 71efe29
commit 78e8e17
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/pkg/pullsync/metrics.go b/pkg/pullsync/metrics.go
@@ -12,6 +12,7 @@ import (
 type metrics struct {
 	Offered       prometheus.Counter     // number of chunks offered
 	Wanted        prometheus.Counter     // number of chunks wanted
+	MissingChunks prometheus.Counter     // number of reserve get errs
 	Delivered     prometheus.Counter     // number of chunk deliveries
 	Sent          prometheus.Counter     // number of chunks sent
 	DuplicateRuid prometheus.Counter     // number of duplicate RUID requests we got
@@ -34,6 +35,12 @@ func newMetrics() metrics {
 			Name:      "chunks_wanted",
 			Help:      "Total chunks wanted.",
 		}),
+		MissingChunks: prometheus.NewCounter(prometheus.CounterOpts{
+			Namespace: m.Namespace,
+			Subsystem: subsystem,
+			Name:      "missing_chunks",
+			Help:      "Total reserve get errors.",
+		}),
 		Delivered: prometheus.NewCounter(prometheus.CounterOpts{
 			Namespace: m.Namespace,
 			Subsystem: subsystem,

diff --git a/pkg/pullsync/pullsync.go b/pkg/pullsync/pullsync.go
@@ -474,6 +474,7 @@ func (s *Syncer) processWant(ctx context.Context, o *pb.Offer, w *pb.Want) ([]sw
 			if err != nil {
 				s.logger.Error(err, "processing want: unable to find chunk", "chunk_address", addr, "batch_id", ch.BatchID)
 				chunks = append(chunks, swarm.NewChunk(swarm.ZeroAddress, nil))
+				s.metrics.MissingChunks.Inc()
 				continue
 			}
 			chunks = append(chunks, c)