PMM-13477 Support MongoDB 8.0

Author: BupycHuk

exporter/metrics.go

@@ -52,6 +52,7 @@ var (
 	prefixes = [][]string{
 		{"serverStatus.wiredTiger.transaction", "ss_wt_txn"},
 		{"serverStatus.wiredTiger", "ss_wt"},
+		{"serverStatus.queues.execution", "ss_wt_concurrentTransactions"},
 		{"serverStatus", "ss"},
 		{"replSetGetStatus", "rs"},
 		{"systemMetrics", "sys"},
@@ -105,6 +106,7 @@ var (
 		"serverStatus.opcountersRepl.":                    "legacy_op_type",
 		"serverStatus.transactions.commitTypes.":          "commit_type",
 		"serverStatus.wiredTiger.concurrentTransactions.": "txn_rw_type",
+		"serverStatus.queues.execution.":                  "txn_rw_type",
 		"serverStatus.wiredTiger.perf.":                   "perf_bucket",
 		"systemMetrics.disks.":                            "device_name",
 	}

exporter/replset_status_collector.go

@@ -85,15 +85,21 @@ func (d *replSetGetStatusCollector) collect(ch chan<- prometheus.Metric) {
 	logger.Debug("replSetGetStatus result:")
 	debugResult(logger, m)
 
-	for _, metric := range makeMetrics("replset", m, d.topologyInfo.baseLabels(), d.compatibleMode) {
+	for _, metric := range makeMetrics("", m, d.topologyInfo.baseLabels(), d.compatibleMode) {
 		ch <- metric
 	}
-	if d.compatibleMode && strings.HasPrefix(d.version.VersionString, "8.") {
-		logger.Infof("collecting compatibility metrics for version %s", d.version.VersionString)
-		metrics := replSetMetrics(m, logger)
-		for _, metric := range metrics {
+
+	if strings.HasPrefix(d.version.VersionString, "8.") {
+		for _, metric := range makeMetrics("rs", m, d.topologyInfo.baseLabels(), d.compatibleMode) {
 			ch <- metric
 		}
+		if d.compatibleMode {
+			logger.Infof("collecting compatibility metrics for version %s", d.version.VersionString)
+			metrics := replSetMetrics(m, logger)
+			for _, metric := range metrics {
+				ch <- metric
+			}
+		}
 	}
 }
 

exporter/v1_compatibility.go

@@ -473,10 +473,22 @@ func conversions() []conversion {
 			oldName: "mongodb_mongod_wiredtiger_transactions_checkpoint_milliseconds_total",
 			newName: "mongodb_ss_wt_txn_transaction_checkpoint_total_time_msecs",
 		},
+		{
+			oldName: "mongodb_mongod_wiredtiger_transactions_checkpoint_milliseconds_total",
+			newName: "mongodb_ss_wt_checkpoint_total_time_msecs",
+		},
 		{
 			oldName: "mongodb_mongod_wiredtiger_transactions_running_checkpoints",
 			newName: "mongodb_ss_wt_txn_transaction_checkpoint_currently_running",
 		},
+		{
+			oldName: "mongodb_mongod_wiredtiger_transactions_running_checkpoints",
+			newName: "mongodb_ss_wt_checkpoint_currently_running",
+		},
+		{
+			oldName: "mongodb_ss_tcmalloc_tcmalloc_thread_cache_free_bytes",
+			newName: "mongodb_ss_tcmalloc_tcmalloc_thread_cache_free",
+		},
 		{
 			oldName:     "mongodb_mongod_wiredtiger_transactions_total",
 			prefix:      "mongodb_ss_wt_txn_transactions",
@@ -577,6 +589,15 @@ func conversions() []conversion {
 				"max_time_msecs": "max",
 			},
 		},
+		{
+			oldName:     "mongodb_mongod_wiredtiger_transactions_checkpoint_milliseconds",
+			prefix:      "mongodb_ss_wt_checkpoint",
+			suffixLabel: "type",
+			suffixMapping: map[string]string{
+				"min_time_msecs": "min",
+				"max_time_msecs": "max",
+			},
+		},
 		{
 			oldName:          "mongodb_mongod_global_lock_current_queue",
 			prefix:           "mongodb_mongod_global_lock_current_queue",