collect Monitor errors for testing

This commit is contained in:
Jim Minter 2020-11-18 10:24:04 -06:00
Родитель f7b0595598
Коммит 4815f059b4
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 0730CBDA10D1A2D3
1 изменённых файлов: 5 добавлений и 1 удалений

Просмотреть файл

@ -97,12 +97,13 @@ func NewMonitor(ctx context.Context, log *logrus.Entry, restConfig *rest.Config,
}
// Monitor checks the API server health of a cluster
func (mon *Monitor) Monitor(ctx context.Context) {
func (mon *Monitor) Monitor(ctx context.Context) (errs []error) {
mon.log.Debug("monitoring")
// If API is not returning 200, don't need to run the next checks
statusCode, err := mon.emitAPIServerHealthzCode(ctx)
if err != nil {
errs = append(errs, err)
mon.log.Printf("%s: %s", runtime.FuncForPC(reflect.ValueOf(mon.emitAPIServerHealthzCode).Pointer()).Name(), err)
mon.emitGauge("monitor.clustererrors", 1, map[string]string{"monitor": runtime.FuncForPC(reflect.ValueOf(mon.emitAPIServerHealthzCode).Pointer()).Name()})
}
@ -129,11 +130,14 @@ func (mon *Monitor) Monitor(ctx context.Context) {
} {
err = f(ctx)
if err != nil {
errs = append(errs, err)
mon.log.Printf("%s: %s", runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name(), err)
mon.emitGauge("monitor.clustererrors", 1, map[string]string{"monitor": runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()})
// keep going
}
}
return
}
func (mon *Monitor) emitFloat(m string, value float64, dims map[string]string) {