Merge pull request #90 from zianazhao/master

zero3233 · web-flow · commit 8c73ea6f8080 · 2022-11-17T19:31:29.000+08:00
fix-dts
diff --git a/pkg/collector/handler_dts.go b/pkg/collector/handler_dts.go
@@ -172,7 +172,7 @@ func (h *dtsHandler) getReplicationSeries(m *metric.TcmMetric, ins instance.TcIn
 	for _, replication := range replications.Response.JobList {
 		ql := map[string]string{
 			"replicationjobid":   *replication.JobId,
-			"replicationjob_ame": *replication.JobName,
+			"replicationjob_name": *replication.JobName,
 		}
 		s, err := metric.NewTcmSeries(m, ql, ins)
 		if err != nil {
diff --git a/pkg/collector/handler_qaap.go b/pkg/collector/handler_qaap.go
@@ -173,6 +173,7 @@ func (h *QaapHandler) getListenerIdSeries(m *metric.TcmMetric, ins instance.TcIn
 				"listenerId":       *tcpListenersInfo.ListenerId,
 				"originServerInfo": *realServerSet.RealServerIP,
 				"protocol":         *tcpListenersInfo.Protocol,
+				"listenerName":     *tcpListenersInfo.ListenerName,
 			}
 			s, err := metric.NewTcmSeries(m, ql, ins)
 			if err != nil {
@@ -192,6 +193,7 @@ func (h *QaapHandler) getListenerIdSeries(m *metric.TcmMetric, ins instance.TcIn
 				"listenerId":       *udpListenersInfo.ListenerId,
 				"originServerInfo": *realServerSet.RealServerIP,
 				"protocol":         *udpListenersInfo.Protocol,
+				"listenerName":     *udpListenersInfo.ListenerName,
 			}
 			s, err := metric.NewTcmSeries(m, ql, ins)
 			if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,7 @@ func (h dtsHandler) getReplicationSeries(m metric.TcmMetric, ins instance.TcIn`
`172`	`172`	`for _, replication := range replications.Response.JobList {`
`173`	`173`	`ql := map[string]string{`
`174`	`174`	`"replicationjobid": *replication.JobId,`
`175`		`- "replicationjob_ame": *replication.JobName,`
	`175`	`+ "replicationjob_name": *replication.JobName,`
`176`	`176`	`}`
`177`	`177`	`s, err := metric.NewTcmSeries(m, ql, ins)`
`178`	`178`	`if err != nil {`