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
|
package provider
import (
"github.com/go-kit/kit/metrics"
"github.com/go-kit/kit/metrics/statsd"
)
type statsdProvider struct {
s *statsd.Statsd
stop func()
}
// NewStatsdProvider wraps the given Statsd object and stop func and returns a
// Provider that produces Statsd metrics. A typical stop function would be
// ticker.Stop from the ticker passed to the SendLoop helper method.
func NewStatsdProvider(s *statsd.Statsd, stop func()) Provider {
return &statsdProvider{
s: s,
stop: stop,
}
}
// NewCounter implements Provider.
func (p *statsdProvider) NewCounter(name string) metrics.Counter {
return p.s.NewCounter(name, 1.0)
}
// NewGauge implements Provider.
func (p *statsdProvider) NewGauge(name string) metrics.Gauge {
return p.s.NewGauge(name)
}
// NewHistogram implements Provider, returning a StatsD Timing that accepts
// observations in milliseconds. The sample rate is fixed at 1.0. The bucket
// parameter is ignored.
func (p *statsdProvider) NewHistogram(name string, _ int) metrics.Histogram {
return p.s.NewTiming(name, 1.0)
}
// Stop implements Provider, invoking the stop function passed at construction.
func (p *statsdProvider) Stop() {
p.stop()
}
|
