Raidman

Go Riemann client

package main
import (
"github.com/amir/raidman"
)
funcmain() {
c, err:=raidman.Dial("tcp", "localhost:5555")
iferr!=nil {
panic(err)
}
varevent=&raidman.Event{
State: "success",
Host: "raidman",
Service: "raidman-sample",
Metric: 100,
Ttl: 10,
}
// send one eventerr=c.Send(event)
iferr!=nil {
panic(err)
}
// send multiple events at onceerr=c.SendMulti([]*raidman.Event{
&raidman.Event{
State: "success",
Host: "raidman",
Service: "raidman-sample",
Metric: 100,
Ttl: 10,
},
&raidman.Event{
State: "failure",
Host: "raidman",
Service: "raidman-sample",
Metric: 100,
Ttl: 10,
},
&raidman.Event{
State: "success",
Host: "raidman",
Service: "raidman-sample",
Metric: 100,
Ttl: 10,
},
})
iferr!=nil {
panic(err)
}
events, err:=c.Query("host = \"raidman\"")
iferr!=nil {
panic(err)
}
iflen(events) <1 {
panic("Submitted event not found")
}
c.Close()
}