Add metric for connectedness

Author: konradkonrad

rolling-shutter/p2p/dht.go

@@ -92,6 +92,7 @@ func findPeers(ctx context.Context, h host.Host, d discovery.Discoverer, ns stri
 				if p.ID == h.ID() {
 					continue
 				}
+				metricsP2PPeerConnectedness.WithLabelValues(p.ID.String()).Add(float64(h.Network().Connectedness(p.ID)))
 				if h.Network().Connectedness(p.ID) != network.Connected {
 					_, err = h.Network().DialPeer(ctx, p.ID)
 					if err != nil {

rolling-shutter/p2p/metrics.go

@@ -31,11 +31,20 @@ var metricsP2PPeerTuples = prometheus.NewGaugeVec(
 	prometheus.GaugeOpts{
 		Namespace: "shutter",
 		Subsystem: "p2p",
-		Name:      "dialed_peer",
-		Help:      "Collection of the encountered peer tuples",
+		Name:      "peer_candidate",
+		Help:      "Collection of the encountered peer tuples.",
 	},
 	[]string{"peer_id", "peer_ip"})
 
+var metricsP2PPeerConnectedness = prometheus.NewGaugeVec(
+	prometheus.GaugeOpts{
+		Namespace: "shutter",
+		Subsystem: "p2p",
+		Name:      "peer_connectedness",
+		Help:      "Collection of the connectedness (0=NotConnected; 1=Connected; 2=CanConnect; 3=CannotConnect) to a peer ID.",
+	},
+	[]string{"peer_id"})
+
 func collectPeerAddresses(peer peer.AddrInfo) {
 	for _, multiAddr := range peer.Addrs {
 		metricsP2PPeerTuples.WithLabelValues(peer.ID.String(), multiAddr.String()).Add(1)