new

Author: fuguohong1024

.idea/workspace.xml

@@ -2,9 +2,7 @@ package api
 
 import (
 	"encoding/json"
-	"fmt"
 	"github.com/prometheus/client_golang/prometheus"
-	log "github.com/sirupsen/logrus"
 )
 
 // 定义desc,调用MustNewConstMetric生产指标并通过channel传递数据
@@ -97,8 +95,7 @@ func (ScrapeNode) Scrape(client *MqClient, ch chan<- prometheus.Metric) error {
 	var t node
 	err = json.Unmarshal(data, &t)
 	if err != nil {
-		reason := fmt.Sprintf("%v,%v", endpoint, err)
-		log.Errorf("Unmarshal  JSON err:%v", endpoint, reason)
+		return err
 	}
 	// 设定值
 	for _, v := range t {

api/node.go

@@ -2,9 +2,7 @@ package api
 
 import (
 	"encoding/json"
-	"fmt"
 	"github.com/prometheus/client_golang/prometheus"
-	log "github.com/sirupsen/logrus"
 )
 
 // 定义desc,调用MustNewConstMetric生产指标并通过channel传递数据
@@ -81,8 +79,7 @@ func (ScrapeOverview) Scrape(client *MqClient, ch chan<- prometheus.Metric) erro
 	var t overview
 	err = json.Unmarshal(data, &t)
 	if err != nil {
-		reason := fmt.Sprintf("%v,%v", endpoint, err)
-		log.Errorf("Unmarshal  JSON err:%v", endpoint, reason)
+		return err
 	}
 	// 设定值
 	ch <- prometheus.MustNewConstMetric(overviewhealth, prometheus.GaugeValue, 1.0, endpoint)

api/overview.go

@@ -2,9 +2,7 @@ package api
 
 import (
 	"encoding/json"
-	"fmt"
 	"github.com/prometheus/client_golang/prometheus"
-	log "github.com/sirupsen/logrus"
 )
 
 var (
@@ -60,8 +58,7 @@ func (ScrapeQueue) Scrape(client *MqClient, ch chan<- prometheus.Metric) error {
 	var t queue
 	err = json.Unmarshal(data, &t)
 	if err != nil {
-		reason := fmt.Sprintf("%v,%v", endpoint, err)
-		log.Errorf("Unmarshal  JSON err:%v", endpoint, reason)
+		return err
 	}
 	for _, v := range t {
 		ch <- prometheus.MustNewConstMetric(queuehealth, prometheus.GaugeValue, 1.0, endpoint)

api/queue.go

@@ -36,9 +36,9 @@ type MqClient struct {
 
 // 赋值MqOpts
 func (m *MqOpts) AddFlag() {
-	flag.StringVar(&m.Url, "mq.url", "http://testmojing.ts/api", "HTTP API address of a mq server or agent. (prefix with https:// to connect over HTTPS)")
-	flag.StringVar(&m.Username, "mq.user", "user", "mq username")
-	flag.StringVar(&m.Password, "mq.pwd", "2Jv4v3Qjrx", "mq password")
+	flag.StringVar(&m.Url, "mq.url", "http://127.0.0.1:15672/api", "HTTP API address of a mq server or agent. (prefix with https:// to connect over HTTPS)")
+	flag.StringVar(&m.Username, "mq.user", "admin", "mq username")
+	flag.StringVar(&m.Password, "mq.pwd", "123456", "mq password")
 	//flag.StringVar(&m.UA, "harbor-ua", "harbor_exporter", "user agent of the harbor http client")
 	flag.DurationVar(&m.Timeout, "timeout", time.Second*5, "Timeout on HTTP requests to the harbor API.")
 	//flag.BoolVar(&m.Insecure, "insecure", true, "Disable TLS host verification.")

api/rabbitmq.go

@@ -4,7 +4,7 @@ After=network.target
 
 [Service]
 Type=simple
-ExecStart=/export/rabbitmq_exporter  --mq.user=admin  --mq.passwd=123456
+ExecStart=/export/rabbitmq_exporter  --mq.user=admin  --mq.pwd=123456
 Restart=on-failure
 [Install]
 WantedBy=multi-user.target