From a3feddd8ed4df6dce396480b8234124e09997112 Mon Sep 17 00:00:00 2001 From: Cameron Sparr Date: Wed, 18 Nov 2015 14:32:29 -0700 Subject: [PATCH] Riemann output: remove some of the object referencing/dereferencing closes #378 closes #379 --- CHANGELOG.md | 8 ++++++++ outputs/riemann/riemann.go | 15 +++++++-------- 2 files changed, 15 insertions(+), 8 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 525e866f6..a1eb39641 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,13 @@ ## v0.2.3 [unreleased] +### Release Notes +- Riemann output added + +### Features +- [#379](https://github.com/influxdb/telegraf/pull/379): Riemann output, thanks @allenj! + +### Bugfixes + ## v0.2.2 [2015-11-18] ### Release Notes diff --git a/outputs/riemann/riemann.go b/outputs/riemann/riemann.go index 789e09691..1a02216e6 100644 --- a/outputs/riemann/riemann.go +++ b/outputs/riemann/riemann.go @@ -14,7 +14,7 @@ type Riemann struct { URL string Transport string - client raidman.Client + client *raidman.Client } var sampleConfig = ` @@ -31,7 +31,7 @@ func (r *Riemann) Connect() error { return err } - r.client = *c + r.client = c return nil } @@ -56,7 +56,7 @@ func (r *Riemann) Write(points []*client.Point) error { var events []*raidman.Event for _, p := range points { ev := buildEvent(p) - events = append(events, &ev) + events = append(events, ev) } var senderr = r.client.SendMulti(events) @@ -68,10 +68,9 @@ func (r *Riemann) Write(points []*client.Point) error { return nil } -func buildEvent(p *client.Point) raidman.Event { - host := p.Tags()["host"] - - if len(host) == 0 { +func buildEvent(p *client.Point) *raidman.Event { + host, ok := p.Tags()["host"] + if !ok { hostname, err := os.Hostname() if err != nil { host = "unknown" @@ -86,7 +85,7 @@ func buildEvent(p *client.Point) raidman.Event { Metric: p.Fields()["value"], } - return *event + return event } func init() {