Add sentinel_peer_info metric for Sentinel peer discovery

exporter/exporter.go

@@ -71,6 +71,7 @@ type Options struct {
 	InclConfigMetrics              bool
 	InclModulesMetrics             bool
 	InclSearchIndexesMetrics       bool
+	InclSentinelPeerInfo           bool
 	CheckSearchIndexes             string
 	DisableExportingKeyValues      bool
 	ExcludeLatencyHistogramMetrics bool
@@ -568,6 +569,7 @@ func NewRedisExporter(uri string, opts Options) (*Exporter, error) {
 		"search_index_number_of_uses_total":                  {txt: "Number of times the index has been used", lbls: []string{"index_name"}},
 		"search_index_cleaning":                              {txt: "Index deletion flag. A value of 1 indicates index deletion is in progress", lbls: []string{"index_name"}},
 		"sentinel_master_ckquorum_status":                    {txt: "Master ckquorum status", lbls: []string{"master_name", "message"}},
+		"sentinel_peer_info":                                 {txt: "Other Sentinel peers discovered via SENTINEL SENTINELS (one scrape from one Sentinel)", lbls: []string{"master_name", "master_address", "name", "ip", "port", "runid", "flags"}},
 		"sentinel_master_ok_sentinels":                       {txt: "The number of okay sentinels monitoring this master", lbls: []string{"master_name", "master_address"}},
 		"sentinel_master_ok_slaves":                          {txt: "The number of okay slaves of the master", lbls: []string{"master_name", "master_address"}},
 		"sentinel_master_sentinels":                          {txt: "The number of sentinels monitoring this master", lbls: []string{"master_name", "master_address"}},
@@ -614,6 +616,10 @@ func NewRedisExporter(uri string, opts Options) (*Exporter, error) {
 		e.metricDescriptions[k] = newMetricDescr(opts.Namespace, k, desc.txt, desc.lbls)
 	}
 
+	if !opts.InclSentinelPeerInfo {
+		delete(e.metricDescriptions, "sentinel_peer_info")
+	}
+
 	if e.options.MetricsPath == "" {
 		e.options.MetricsPath = "/metrics"
 	}

exporter/info_test.go

@@ -43,7 +43,6 @@ func TestKeyspaceStringParser(t *testing.T) {
 		},
 	}
 
-	log.SetLevel(log.DebugLevel)
 	for _, tst := range tsts {
 		if kt, kx, ttl, kc, ok := parseDBKeyspaceString(tst.db, tst.stats); true {
 

exporter/sentinels.go

@@ -144,6 +144,12 @@ func (e *Exporter) processSentinelSentinels(ch chan<- prometheus.Metric, sentine
 
 	// If we are here then this master is in ok state
 	masterOkSentinels := 1
+	masterName := ""
+	masterAddr := ""
+	if len(labels) >= 2 {
+		masterName = labels[0]
+		masterAddr = labels[1]
+	}
 
 	for _, sentinelDetail := range sentinelDetails {
 		sentinelDetailMap, err := redis.StringMap(sentinelDetail, nil)
@@ -152,6 +158,30 @@ func (e *Exporter) processSentinelSentinels(ch chan<- prometheus.Metric, sentine
 			continue
 		}
 
+		name := ""
+		if v, ok := sentinelDetailMap["name"]; ok {
+			name = v
+		}
+		ip := ""
+		if v, ok := sentinelDetailMap["ip"]; ok {
+			ip = v
+		}
+		port := ""
+		if v, ok := sentinelDetailMap["port"]; ok {
+			port = v
+		}
+		runid := ""
+		if v, ok := sentinelDetailMap["runid"]; ok {
+			runid = v
+		}
+		flags := ""
+		if v, ok := sentinelDetailMap["flags"]; ok {
+			flags = v
+		}
+		if e.options.InclSentinelPeerInfo {
+			e.registerConstMetricGauge(ch, "sentinel_peer_info", 1, masterName, masterAddr, name, ip, port, runid, flags)
+		}
+
 		sentinelFlags, ok := sentinelDetailMap["flags"]
 		if !ok {
 			continue