stream: add set cache metrics

ethersphere · Nov 28, 2019 · eb2625c · eb2625c
1 parent 52fb861
commit eb2625c
Showing 1 changed file with 9 additions and 1 deletion.
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
@@ -66,7 +71,7 @@ func NewSyncProvider(ns *storage.NetStore, kad *network.Kademlia, autostart bool
 	if err != nil {
 		panic(err)
 	}
-	sc, err := lru.New(cacheCapacity)
+	sc, err := lru.New(setCacheCapacity)
 	if err != nil {
 		panic(err)
 	}
@@ -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()