blob: f8074c04576823b117d07ce726249d53b7d8a61b [file] [log] [blame]
Matteo Scandolo9a2772a2018-11-19 14:56:26 -08001package metrics
2
3import (
4 "time"
5)
6
7type Logger interface {
8 Printf(format string, v ...interface{})
9}
10
11func Log(r Registry, freq time.Duration, l Logger) {
12 LogScaled(r, freq, time.Nanosecond, l)
13}
14
15// Output each metric in the given registry periodically using the given
16// logger. Print timings in `scale` units (eg time.Millisecond) rather than nanos.
17func LogScaled(r Registry, freq time.Duration, scale time.Duration, l Logger) {
18 du := float64(scale)
19 duSuffix := scale.String()[1:]
20
21 for _ = range time.Tick(freq) {
22 r.Each(func(name string, i interface{}) {
23 switch metric := i.(type) {
24 case Counter:
25 l.Printf("counter %s\n", name)
26 l.Printf(" count: %9d\n", metric.Count())
27 case Gauge:
28 l.Printf("gauge %s\n", name)
29 l.Printf(" value: %9d\n", metric.Value())
30 case GaugeFloat64:
31 l.Printf("gauge %s\n", name)
32 l.Printf(" value: %f\n", metric.Value())
33 case Healthcheck:
34 metric.Check()
35 l.Printf("healthcheck %s\n", name)
36 l.Printf(" error: %v\n", metric.Error())
37 case Histogram:
38 h := metric.Snapshot()
39 ps := h.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
40 l.Printf("histogram %s\n", name)
41 l.Printf(" count: %9d\n", h.Count())
42 l.Printf(" min: %9d\n", h.Min())
43 l.Printf(" max: %9d\n", h.Max())
44 l.Printf(" mean: %12.2f\n", h.Mean())
45 l.Printf(" stddev: %12.2f\n", h.StdDev())
46 l.Printf(" median: %12.2f\n", ps[0])
47 l.Printf(" 75%%: %12.2f\n", ps[1])
48 l.Printf(" 95%%: %12.2f\n", ps[2])
49 l.Printf(" 99%%: %12.2f\n", ps[3])
50 l.Printf(" 99.9%%: %12.2f\n", ps[4])
51 case Meter:
52 m := metric.Snapshot()
53 l.Printf("meter %s\n", name)
54 l.Printf(" count: %9d\n", m.Count())
55 l.Printf(" 1-min rate: %12.2f\n", m.Rate1())
56 l.Printf(" 5-min rate: %12.2f\n", m.Rate5())
57 l.Printf(" 15-min rate: %12.2f\n", m.Rate15())
58 l.Printf(" mean rate: %12.2f\n", m.RateMean())
59 case Timer:
60 t := metric.Snapshot()
61 ps := t.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
62 l.Printf("timer %s\n", name)
63 l.Printf(" count: %9d\n", t.Count())
64 l.Printf(" min: %12.2f%s\n", float64(t.Min())/du, duSuffix)
65 l.Printf(" max: %12.2f%s\n", float64(t.Max())/du, duSuffix)
66 l.Printf(" mean: %12.2f%s\n", t.Mean()/du, duSuffix)
67 l.Printf(" stddev: %12.2f%s\n", t.StdDev()/du, duSuffix)
68 l.Printf(" median: %12.2f%s\n", ps[0]/du, duSuffix)
69 l.Printf(" 75%%: %12.2f%s\n", ps[1]/du, duSuffix)
70 l.Printf(" 95%%: %12.2f%s\n", ps[2]/du, duSuffix)
71 l.Printf(" 99%%: %12.2f%s\n", ps[3]/du, duSuffix)
72 l.Printf(" 99.9%%: %12.2f%s\n", ps[4]/du, duSuffix)
73 l.Printf(" 1-min rate: %12.2f\n", t.Rate1())
74 l.Printf(" 5-min rate: %12.2f\n", t.Rate5())
75 l.Printf(" 15-min rate: %12.2f\n", t.Rate15())
76 l.Printf(" mean rate: %12.2f\n", t.RateMean())
77 }
78 })
79 }
80}