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

Update code style

This commit is contained in:
Aurélien Hébert 2016-08-09 11:53:42 +02:00
parent be7b64172a
commit f4d802d9a8
2 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugins/outputs/warp10/README.md
View File

@ -4,19 +4,18 @@ Telegraph plugin to push metrics on Warp10
### Telegraph output for Warp10 ###
* Execute a post http on Warp10 at every flush time configured in telegraph in order to push the metrics collected
Execute a post http on Warp10 at every flush time configured in telegraph in order to push the metrics collected
### Config ###
* Add following instruction in the config file (Output part)
Add following instruction in the config file (Output part)
```
[[outputs.warp10]]
warpUrl = "https://warp1.cityzendata.net/api/v0/update"
warpUrl = "http://localhost:4242"
token = "token"
prefix = "telegraf."
debug = false
```
### Contact ###

20
plugins/outputs/warp10/warp10.go
View File

@ -24,10 +24,10 @@ type Warp10 struct {
var sampleConfig = `
# prefix for metrics class Name
prefix = "telegraf."
## POST HTTP Mode ##
prefix = "Prefix"
## POST HTTP(or HTTPS) ##
# Url name of the Warp 10 server
warp_url = "localhost:4242/"
warp_url = "WarpUrl"
# Token to access your app on warp 10
token = "Token"
`
@ -47,7 +47,7 @@ func (o *Warp10) Write(metrics []telegraf.Metric) error {
if len(metrics) == 0 {
return nil
}
var timeNow = time.Now()
var now = time.Now()
collectString := make([]string, 0)
index := 0
for _, mm := range metrics {
@ -56,20 +56,20 @@ func (o *Warp10) Write(metrics []telegraf.Metric) error {
metric := &MetricLine{
Metric: fmt.Sprintf("%s%s", o.Prefix, mm.Name()+"."+k),
Timestamp: timeNow.Unix() * 1000000,
Timestamp: now.Unix() * 1000000,
}
metricValue, buildError := buildValue(v)
if buildError != nil {
fmt.Printf("Warp: %s\n", buildError.Error())
metricValue, err := buildValue(v)
if err != nil {
log.Printf("Warp: %s\n", err.Error())
continue
}
metric.Value = metricValue
tagsSlice := buildTags(mm.Tags())
metric.Tags = fmt.Sprint(strings.Join(tagsSlice, ","))
metric.Tags = strings.Join(tagsSlice, ",")
messageLine := fmt.Sprintf("%v// %s{%s} %v \n", metric.Timestamp, metric.Metric, metric.Tags, metric.Value)
messageLine := fmt.Sprintf("%d// %s{%s} %s\n", metric.Timestamp, metric.Metric, metric.Tags, metric.Value)
collectString = append(collectString, messageLine)
index += 1