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

0.3.0 outputs: riemann

This commit is contained in:
Cameron Sparr 2015-12-19 14:55:44 -07:00
parent 06a78510db
commit 9a5ced8b37
1 changed files with 23 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
outputs/riemann/riemann.go
View File

@ -55,9 +55,11 @@ func (r *Riemann) Write(points []*client.Point) error {
var events []*raidman.Event var events []*raidman.Event
for _, p := range points { for _, p := range points {
ev := buildEvent(p) evs := buildEvents(p)
for _, ev := range evs {
events = append(events, ev) events = append(events, ev)
} }
}
var senderr = r.client.SendMulti(events) var senderr = r.client.SendMulti(events)
if senderr != nil { if senderr != nil {
@ -68,7 +70,9 @@ func (r *Riemann) Write(points []*client.Point) error {
return nil return nil
} }
func buildEvent(p *client.Point) *raidman.Event { func buildEvents(p *client.Point) []*raidman.Event {
events := []*raidman.Event{}
for fieldName, value := range p.Fields() {
host, ok := p.Tags()["host"] host, ok := p.Tags()["host"]
if !ok { if !ok {
hostname, err := os.Hostname() hostname, err := os.Hostname()
@ -79,13 +83,15 @@ func buildEvent(p *client.Point) *raidman.Event {
} }
} }
var event = &raidman.Event{ event := &raidman.Event{
Host: host, Host: host,
Service: p.Name(), Service: p.Name() + "_" + fieldName,
Metric: p.Fields()["value"], Metric: value,
}
events = append(events, event)
} }
return event return events
} }
func init() { func init() {