replSetGetConfigCollector

README.md

@@ -40,6 +40,7 @@ Currently, these metric sources are implemented:
 |\-\-log.level|Only log messages with the given severity or above. Valid levels: [debug, info, warn, error]|\-\-log.level="error"|
 |\-\-disable.diagnosticdata|Disable collecting metrics from getDiagnosticData||
 |\-\-disable.replicasetstatus|Disable collecting metrics from replSetGetStatus||
+|\-\-disable.replicasetconfig|Disable collecting metrics from replSetGetConfig||
 |--version|Show version and exit|
 
  ### Build the exporter

exporter/exporter.go

@@ -54,6 +54,7 @@ type Opts struct {
 	Logger                  *logrus.Logger
 	DisableDiagnosticData   bool
 	DisableReplicasetStatus bool
+	DisableReplicasetConfig bool
 }
 
 var (
@@ -153,6 +154,17 @@ func (e *Exporter) makeRegistry(ctx context.Context, client *mongo.Client, topol
 		registry.MustRegister(&rsgsc)
 	}
 
+	if !e.opts.DisableReplicasetConfig {
+		rsgcc := replSetGetConfigCollector{
+			ctx:            ctx,
+			client:         client,
+			compatibleMode: e.opts.CompatibleMode,
+			logger:         e.opts.Logger,
+			topologyInfo:   topologyInfo,
+		}
+		registry.MustRegister(&rsgcc)
+	}
+
 	return registry
 }
 

exporter/metrics.go

@@ -319,6 +319,9 @@ func processSlice(prefix, k string, v []interface{}, commonLabels map[string]str
 		if state, ok := s["stateStr"].(string); ok {
 			labels["member_state"] = state
 		}
+		if host, ok := s["host"].(string); ok {
+			labels["member_idx"] = host
+		}
 
 		metrics = append(metrics, makeMetrics(prefix+k, s, labels, compatibleMode)...)
 	}

exporter/replset_config_collector.go

@@ -0,0 +1,80 @@
+// mongodb_exporter
+// Copyright (C) 2017 Percona LLC
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program. If not, see <https://www.gnu.org/licenses/>.
+
+package exporter
+
+import (
+	"context"
+
+	"github.com/pkg/errors"
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/sirupsen/logrus"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+// const (
+// 	replicationNotEnabled        = 76
+// 	replicationNotYetInitialized = 94
+// )
+
+type replSetGetConfigCollector struct {
+	ctx            context.Context
+	client         *mongo.Client
+	compatibleMode bool
+	logger         *logrus.Logger
+	topologyInfo   labelsGetter
+}
+
+func (d *replSetGetConfigCollector) Describe(ch chan<- *prometheus.Desc) {
+	prometheus.DescribeByCollect(d, ch)
+}
+
+func (d *replSetGetConfigCollector) Collect(ch chan<- prometheus.Metric) {
+	cmd := bson.D{{Key: "replSetGetConfig", Value: "1"}}
+	res := d.client.Database("admin").RunCommand(d.ctx, cmd)
+
+	var m bson.M
+
+	if err := res.Decode(&m); err != nil {
+		if e, ok := err.(mongo.CommandError); ok {
+			if e.Code == replicationNotYetInitialized || e.Code == replicationNotEnabled {
+				return
+			}
+		}
+		d.logger.Errorf("cannot get replSetGetConfig: %s", err)
+
+		return
+	}
+
+	config, ok := m["config"].(bson.M)
+	if !ok {
+		err := errors.Wrapf(errUnexpectedDataType, "%T for data field", m["config"])
+		d.logger.Errorf("cannot decode getDiagnosticData: %s", err)
+
+		return
+	}
+	m = config
+
+	d.logger.Debug("replSetGetConfig result:")
+	debugResult(d.logger, m)
+
+	for _, metric := range makeMetrics("cfg", m, d.topologyInfo.baseLabels(), d.compatibleMode) {
+		ch <- metric
+	}
+}
+
+var _ prometheus.Collector = (*replSetGetConfigCollector)(nil)

main.go

@@ -47,6 +47,7 @@ type GlobalFlags struct {
 
 	DisableDiagnosticData   bool `name:"disable.diagnosticdata" help:"Disable collecting metrics from getDiagnosticData"`
 	DisableReplicasetStatus bool `name:"disable.replicasetstatus" help:"Disable collecting metrics from replSetGetStatus"`
+	DisableReplicasetConfig bool `name:"disable.replicasetconfig" help:"Disable collecting metrics from replSetGetConfig"`
 
 	DiscoveringMode bool `name:"discovering-mode" help:"Enable autodiscover collections"`
 	CompatibleMode  bool `name:"compatible-mode" help:"Enable old mongodb-exporter compatible metrics"`
@@ -116,6 +117,7 @@ func buildExporter(opts GlobalFlags) (*exporter.Exporter, error) {
 		WebListenAddress:        opts.WebListenAddress,
 		DisableDiagnosticData:   opts.DisableDiagnosticData,
 		DisableReplicasetStatus: opts.DisableReplicasetStatus,
+		DisableReplicasetConfig: opts.DisableReplicasetConfig,
 		DirectConnect:           opts.DirectConnect,
 	}
 

main_test.go

@@ -18,6 +18,7 @@ func TestBuildExporter(t *testing.T) {
 
 		DisableDiagnosticData:   true,
 		DisableReplicasetStatus: true,
+		DisableReplicasetConfig: true,
 
 		CompatibleMode: true,
 	}