rafthttp: add 'peer_active_total' metrics

Signed-off-by: Gyu-Ho Lee <[email protected]>
etcd-io · Apr 6, 2017 · 122eae6 · 122eae6
1 parent e1cf766
commit 122eae6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/rafthttp/metrics.go b/rafthttp/metrics.go
@@ -53,6 +53,13 @@ var (
 		[]string{"From"},
 	)
 
+	activePeers = prometheus.NewGauge(prometheus.GaugeOpts{
+		Namespace: "etcd",
+		Subsystem: "network",
+		Name:      "peer_active_total",
+		Help:      "The total number of active peer connections.",
+	})
+
 	rtts = prometheus.NewHistogramVec(prometheus.HistogramOpts{
 		Namespace: "etcd",
 		Subsystem: "network",
@@ -69,5 +76,6 @@ func init() {
 	prometheus.MustRegister(receivedBytes)
 	prometheus.MustRegister(sentFailures)
 	prometheus.MustRegister(recvFailures)
+	prometheus.MustRegister(activePeers)
 	prometheus.MustRegister(rtts)
 }
diff --git a/rafthttp/peer_status.go b/rafthttp/peer_status.go
@@ -47,6 +47,7 @@ func (s *peerStatus) activate() {
 		plog.Infof("peer %s became active", s.id)
 		s.active = true
 		s.since = time.Now()
+		activePeers.Inc()
 	}
 }
 
@@ -59,6 +60,7 @@ func (s *peerStatus) deactivate(failure failureType, reason string) {
 		plog.Infof("peer %s became inactive", s.id)
 		s.active = false
 		s.since = time.Time{}
+		activePeers.Dec()
 		return
 	}
 	plog.Debugf(msg)