diff --git a/src/service_cmd/runner/runner.go b/src/service_cmd/runner/runner.go index f59ce445..cf7e876e 100644 --- a/src/service_cmd/runner/runner.go +++ b/src/service_cmd/runner/runner.go @@ -38,8 +38,19 @@ type Runner struct { } func NewRunner(s settings.Settings) Runner { + + var store gostats.Store + // use statsd + if s.UseStatsd { + store = gostats.NewStore(gostats.NewTCPStatsdSink(gostats.WithStatsdHost(s.StatsdHost), gostats.WithStatsdPort(s.StatsdPort)), false) + } else { + store = gostats.NewStore(gostats.NewNullSink(), false) + } + + go store.Start(time.NewTicker(10 * time.Second)) + return Runner{ - statsManager: stats.NewStatManager(gostats.NewDefaultStore(), s), + statsManager: stats.NewStatManager(store, s), settings: s, } }