feat(task): include task scheduler metrics on /metrics endpoint

Closes #1223.
pull/10616/head
Mark Rushakoff 2018-10-30 15:12:05 -07:00 committed by Mark Rushakoff
parent 4365ad3d60
commit c3e3b44a75
1 changed files with 1 additions and 0 deletions

View File

@ -250,6 +250,7 @@ func run() error {
logger.Info("Stopping", zap.String("service", "task"))
scheduler.Stop()
}()
reg.MustRegister(scheduler.PrometheusCollectors()...)
// TODO(lh): Replace NopLogReader with real log reader
taskSvc = task.PlatformAdapter(coordinator.New(logger.With(zap.String("service", "task-coordinator")), scheduler, boltStore), taskbackend.NopLogReader{}, scheduler)