dom/telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

enhance coding style gofmt

Browse Source
This commit is contained in:
Roman Plessl
2015-09-14 12:34:34 +02:00
parent b4eb7d3f92
commit da3a590aab
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
outputs/opentsdb/opentsdb.go
View File

@@ -9,7 +9,7 @@ import (
"time" "time"
"github.com/influxdb/influxdb/client" "github.com/influxdb/influxdb/client"
"github.com/influxdb/telegraf/outputs" "github.com/influxdb/telegraf/outputs"
) )
type OpenTSDB struct { type OpenTSDB struct {
@@ -75,7 +75,7 @@ func (o *OpenTSDB) Write(bp client.BatchPoints) error {
Metric: fmt.Sprintf("%s%s", o.Prefix, pt.Measurement), Metric: fmt.Sprintf("%s%s", o.Prefix, pt.Measurement),
Timestamp: timeNow.Unix(), Timestamp: timeNow.Unix(),
} }
metricValue, buildError := buildValue(bp, pt); metricValue, buildError := buildValue(bp, pt)
if buildError != nil { if buildError != nil {
fmt.Printf("OpenTSDB: %s\n", buildError.Error()) fmt.Printf("OpenTSDB: %s\n", buildError.Error())
continue continue
@@ -86,7 +86,7 @@ func (o *OpenTSDB) Write(bp client.BatchPoints) error {
metric.Tags = fmt.Sprint(strings.Join(tagsSlice, " ")) metric.Tags = fmt.Sprint(strings.Join(tagsSlice, " "))
messageLine := fmt.Sprintf("put %s %v %s %s\n", metric.Metric, metric.Timestamp, metric.Value, metric.Tags) messageLine := fmt.Sprintf("put %s %v %s %s\n", metric.Metric, metric.Timestamp, metric.Value, metric.Tags)
if (o.Debug) { if o.Debug {
fmt.Print(messageLine) fmt.Print(messageLine)
} }
_, err := connection.Write([]byte(messageLine)) _, err := connection.Write([]byte(messageLine))