github/mqtt2prometheus
1
0
Fork 0
mirror of https://github.com/hikhvar/mqtt2prometheus.git synced 2026-08-23 21:16:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

gofmt cmd/

Browse Source
This commit is contained in:
Mansour Behabadi
2020-05-22 00:43:09 +10:00
parent 7b5796b042
commit 8d0c1e0f2b
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/mqtt2prometheus.go
+7 -5
View File
@@ -1,17 +1,19 @@
package main
import (
"flag"
"fmt"
"log"
"net/http"
"os"
"flag"
"github.com/eclipse/paho.mqtt.golang"
"github.com/hikhvar/mqtt2prometheus/pkg/metrics"
"github.com/hikhvar/mqtt2prometheus/pkg/mqttclient"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
"fmt"
"github.com/hikhvar/mqtt2prometheus/pkg/config"
"github.com/hikhvar/mqtt2prometheus/pkg/metrics"
"github.com/hikhvar/mqtt2prometheus/pkg/mqttclient"
)
var (
@@ -51,7 +53,7 @@ func main() {
collector := metrics.NewCollector(cfg.Cache.Timeout, cfg.Metrics)
ingest := metrics.NewIngest(collector, cfg.Metrics)
errorChan := make(chan error,1)
errorChan := make(chan error, 1)
err = mqttclient.Subscribe(mqttClientOptions, mqttclient.SubscribeOptions{
Topic: cfg.MQTT.TopicPath + "/+",