aboutsummaryrefslogtreecommitdiffstats
path: root/vendor/github.com/rcrowley/go-metrics/syslog.go
blob: 693f190855c1e7775c4dee0bcf8aef9c5c08d039 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
// +build !windows

package metrics

import (
    "fmt"
    "log/syslog"
    "time"
)

// Output each metric in the given registry to syslog periodically using
// the given syslogger.
func Syslog(r Registry, d time.Duration, w *syslog.Writer) {
    for _ = range time.Tick(d) {
        r.Each(func(name string, i interface{}) {
            switch metric := i.(type) {
            case Counter:
                w.Info(fmt.Sprintf("counter %s: count: %d", name, metric.Count()))
            case Gauge:
                w.Info(fmt.Sprintf("gauge %s: value: %d", name, metric.Value()))
            case GaugeFloat64:
                w.Info(fmt.Sprintf("gauge %s: value: %f", name, metric.Value()))
            case Healthcheck:
                metric.Check()
                w.Info(fmt.Sprintf("healthcheck %s: error: %v", name, metric.Error()))
            case Histogram:
                h := metric.Snapshot()
                ps := h.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
                w.Info(fmt.Sprintf(
                    "histogram %s: count: %d min: %d max: %d mean: %.2f stddev: %.2f median: %.2f 75%%: %.2f 95%%: %.2f 99%%: %.2f 99.9%%: %.2f",
                    name,
                    h.Count(),
                    h.Min(),
                    h.Max(),
                    h.Mean(),
                    h.StdDev(),
                    ps[0],
                    ps[1],
                    ps[2],
                    ps[3],
                    ps[4],
                ))
            case Meter:
                m := metric.Snapshot()
                w.Info(fmt.Sprintf(
                    "meter %s: count: %d 1-min: %.2f 5-min: %.2f 15-min: %.2f mean: %.2f",
                    name,
                    m.Count(),
                    m.Rate1(),
                    m.Rate5(),
                    m.Rate15(),
                    m.RateMean(),
                ))
            case Timer:
                t := metric.Snapshot()
                ps := t.Percentiles([]float64{0.5, 0.75, 0.95, 0.99, 0.999})
                w.Info(fmt.Sprintf(
                    "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-rate: %.2f",
                    name,
                    t.Count(),
                    t.Min(),
                    t.Max(),
                    t.Mean(),
                    t.StdDev(),
                    ps[0],
                    ps[1],
                    ps[2],
                    ps[3],
                    ps[4],
                    t.Rate1(),
                    t.Rate5(),
                    t.Rate15(),
                    t.RateMean(),
                ))
            }
        })
    }
}