stream: add set cache metrics

ethersphere · Nov 28, 2019 · 8d27364 · 8d27364
1 parent 52fb861
commit 8d27364
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/network/stream/sync_provider.go b/network/stream/sync_provider.go
@@ -42,6 +42,11 @@ const (
 	maxBinZeroSyncPeers = 3
 )
 
+var (
+	setCacheMissCount = metrics.GetOrRegisterCounter("network.stream.sync_provider.set.cachemiss", nil)
+	setCacheHitCount  = metrics.GetOrRegisterCounter("network.stream.sync_provider.set.cachehit", nil)
+)
+
 type syncProvider struct {
 	netStore                *storage.NetStore // netstore
 	kad                     *network.Kademlia // kademlia
@@ -204,6 +209,9 @@ func (s *syncProvider) Set(ctx context.Context, addrs ...chunk.Address) error {
 	for _, addr := range addrs {
 		if _, ok := s.setCache.Get(addr); !ok {
 			chunksToSet = append(chunksToSet, addr)
+			setCacheMissCount.Inc(1)
+		} else {
+			setCacheHitCount.Inc(1)
 		}
 	}
 	s.setCacheMtx.RUnlock()