syslog.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. package metrics
  2. import (
  3. "fmt"
  4. "syslog"
  5. "time"
  6. )
  7. func Syslog(r Registry, interval int, w *syslog.Writer) {
  8. for {
  9. for name, c := range r.Counters() {
  10. w.Info(fmt.Sprintf("counter %s: count: %d", name, c.Count()))
  11. }
  12. for name, g := range r.Gauges() {
  13. w.Info(fmt.Sprintf("gauge %s: value: %d", name, g.Value()))
  14. }
  15. for name, h := range r.Healthchecks() {
  16. w.Info(fmt.Sprintf("healthcheck %s: TODO", name, h))
  17. }
  18. for name, h := range r.Histograms() {
  19. ps := h.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
  20. w.Info(fmt.Sprintf(
  21. "histogram %s: count: %d min: %d max: %d mean: %.2f stddev: %.2f median: %.2f 75%%: %.2f 95%%: %.2f 99%%: %.2f 99.9%%: %.2f",
  22. name,
  23. h.Count(),
  24. h.Min(),
  25. h.Max(),
  26. h.Mean(),
  27. h.StdDev(),
  28. ps[0],
  29. ps[1],
  30. ps[2],
  31. ps[3],
  32. ps[4],
  33. ))
  34. }
  35. for name, m := range r.Meters() {
  36. w.Info(fmt.Sprintf(
  37. "meter %s: count: %d 1-min: %.2f 5-min: %.2f 15-min: %.2f mean: %.2f",
  38. name,
  39. m.Count(),
  40. m.Rate1(),
  41. m.Rate5(),
  42. m.Rate15(),
  43. m.RateMean(),
  44. ))
  45. }
  46. for name, t := range r.Timers() {
  47. w.Info(fmt.Sprintf("timer %s: TODO", name, t))
  48. }
  49. time.Sleep(int64(1e9) * int64(interval))
  50. }
  51. }