syslog.go 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  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. r.RunHealthchecks()
  16. for name, h := range r.Healthchecks() {
  17. w.Info(fmt.Sprintf("healthcheck %s: error: %v", name, h.Error()))
  18. }
  19. for name, h := range r.Histograms() {
  20. ps := h.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
  21. w.Info(fmt.Sprintf(
  22. "histogram %s: count: %d min: %d max: %d mean: %.2f stddev: %.2f median: %.2f 75%%: %.2f 95%%: %.2f 99%%: %.2f 99.9%%: %.2f",
  23. name,
  24. h.Count(),
  25. h.Min(),
  26. h.Max(),
  27. h.Mean(),
  28. h.StdDev(),
  29. ps[0],
  30. ps[1],
  31. ps[2],
  32. ps[3],
  33. ps[4],
  34. ))
  35. }
  36. for name, m := range r.Meters() {
  37. w.Info(fmt.Sprintf(
  38. "meter %s: count: %d 1-min: %.2f 5-min: %.2f 15-min: %.2f mean: %.2f",
  39. name,
  40. m.Count(),
  41. m.Rate1(),
  42. m.Rate5(),
  43. m.Rate15(),
  44. m.RateMean(),
  45. ))
  46. }
  47. for name, t := range r.Timers() {
  48. w.Info(fmt.Sprintf(
  49. "timer %s: count: %d min: %d max: %d mean: %.2f stddev: %.2f median: %.2f 75%%: %.2f 95%%: %.2f 99%%: %.2f 99.9%%: %.2f 1-min: %.2f 5-min: %.2f 15-min: %.2f mean: %.2f",
  50. name,
  51. h.Count(),
  52. h.Min(),
  53. h.Max(),
  54. h.Mean(),
  55. h.StdDev(),
  56. ps[0],
  57. ps[1],
  58. ps[2],
  59. ps[3],
  60. ps[4],
  61. m.Rate1(),
  62. m.Rate5(),
  63. m.Rate15(),
  64. m.RateMean(),
  65. ))
  66. }
  67. time.Sleep(int64(1e9) * int64(interval))
  68. }
  69. }