Collect peer info metrics in p2p

Author: konradkonrad

rolling-shutter/p2p/dht.go

@@ -87,6 +87,7 @@ func findPeers(ctx context.Context, h host.Host, d discovery.Discoverer, ns stri
 			newConnections := 0
 			failedDials := 0
 			for _, p := range peers {
+				collectPeerAddresses(p)
 				if p.ID == h.ID() {
 					continue
 				}

rolling-shutter/p2p/metrics.go

@@ -1,6 +1,9 @@
 package p2p
 
-import "github.com/prometheus/client_golang/prometheus"
+import (
+	"github.com/libp2p/go-libp2p/core/peer"
+	"github.com/prometheus/client_golang/prometheus"
+)
 
 var metricsP2PMessageValidationTime = prometheus.NewHistogramVec(
 	prometheus.HistogramOpts{
@@ -24,7 +27,23 @@ var metricsP2PMessageHandlingTime = prometheus.NewHistogramVec(
 	[]string{"topic"},
 )
 
+var metricsP2PPeerTuples = prometheus.NewGaugeVec(
+	prometheus.GaugeOpts{
+		Namespace: "shutter",
+		Subsystem: "p2p",
+		Name:      "dialed_peer",
+		Help:      "Collection of the encountered peer tuples",
+	},
+	[]string{"peer_id", "peer_ip"})
+
+func collectPeerAddresses(peer peer.AddrInfo) {
+	for _, multiAddr := range peer.Addrs {
+		metricsP2PPeerTuples.WithLabelValues(peer.ID.String(), multiAddr.String()).Add(1)
+	}
+}
+
 func init() {
 	prometheus.MustRegister(metricsP2PMessageValidationTime)
 	prometheus.MustRegister(metricsP2PMessageHandlingTime)
+	prometheus.MustRegister(metricsP2PPeerTuples)
 }