对齐版本

Author: zianazhao

pkg/collector/handler_cbs.go

@@ -33,14 +33,6 @@ func (h *cbsHandler) GetNamespace() string {
 }
 
 func (h *cbsHandler) IsMetricVaild(m *metric.TcmMetric) bool {
-	// 暂时过滤nvme盘类指标
-	var dimensions []string
-	for _, v := range m.Meta.SupportDimensions {
-		dimensions = append(dimensions, v)
-	}
-	if util.IsStrInList(dimensions, "vmUuid") {
-		return false
-	}
 	return true
 }
 

pkg/collector/handler_clb7.go

@@ -23,14 +23,6 @@ var (
 		"activeconnratio",
 		"newactiveconnratio",
 		"outtrafficratio",
-		"rsptimeout",
-		"setreqavg",
-		"setreqmax",
-		"setrspavg",
-		"setrspmax",
-		"settotalreq",
-		"vrsptimeout",
-		"vsettotalreq",
 	}
 )
 

pkg/collector/handler_tdmq.go

@@ -2,7 +2,6 @@ package collector
 
 import (
 	"fmt"
-	"strings"
 	"time"
 
 	"github.com/go-kit/log"
@@ -18,19 +17,6 @@ const (
 	TdmqInstanceidKey = "tenant"
 )
 
-var (
-	RocketMQOnlyIncludeMetrics = []string{
-		"ropratein",
-		"roprateout",
-		"ropthroughputin",
-		"ropthroughputout",
-		"ropmsgbacklog",
-		"ropmsgaveragesize",
-		"ropinmessagetotal",
-		"ropgroupcount",
-	}
-)
-
 func init() {
 	registerHandler(TdmqNamespace, defaultHandlerEnabled, NewTdmqHandler)
 }
@@ -50,10 +36,6 @@ func (h *tdmqHandler) GetNamespace() string {
 }
 
 func (h *tdmqHandler) IsMetricVaild(m *metric.TcmMetric) bool {
-	// 暂时只支持 TDMQ RocketMQ 版指标
-	if !util.IsStrInList(RocketMQOnlyIncludeMetrics, strings.ToLower(m.Meta.MetricName)) {
-		return false
-	}
 	_, ok := excludeMetricName[m.Meta.MetricName]
 	if ok {
 		return false