We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8d63f41 commit 98a02e4Copy full SHA for 98a02e4
meter.go
@@ -36,20 +36,18 @@ func newMeter(logger LeveledLogger) *meterS {
36
}
37
38
func (m *meterS) Run(collectInterval time.Duration) {
39
- go func() {
40
- ticker := time.NewTicker(collectInterval)
41
- defer ticker.Stop()
42
- for {
43
- select {
44
- case <-m.done:
45
- return
46
- case <-ticker.C:
47
- if sensor.Agent().Ready() {
48
- go sensor.Agent().SendMetrics(m.collectMetrics())
49
- }
+ ticker := time.NewTicker(collectInterval)
+ defer ticker.Stop()
+ for {
+ select {
+ case <-m.done:
+ return
+ case <-ticker.C:
+ if sensor.Agent().Ready() {
+ go sensor.Agent().SendMetrics(m.collectMetrics())
50
51
52
- }()
+ }
53
54
55
func (m *meterS) Stop() {
0 commit comments