Versions in this module Expand all Collapse all v0 v0.0.0 Apr 9, 2020 Changes in this version + type IReporter struct + func (_m *IReporter) AddHostnameSuffix(_a0 string) + func (_m *IReporter) AddStat(key string, val interface{}) + func (_m *IReporter) ClearAll() + func (_m *IReporter) ClearStat(key string) + func (_m *IReporter) ClearStatFns() + func (_m *IReporter) ClearStats() + func (_m *IReporter) GetKafkaLogWriter() io.Writer + func (_m *IReporter) GetStat(key string) interface{} + func (_m *IReporter) Health() health.Event + func (_m *IReporter) HealthHandler(w http.ResponseWriter, req *http.Request) + func (_m *IReporter) Initialize() (bool, error) + func (_m *IReporter) KafkaHealthy() (bool, error) + func (_m *IReporter) PersistStat(key string, val interface{}) + func (_m *IReporter) RegisterStatFn(name string, fn func(health.IReporter)) + func (_m *IReporter) ReportHealth() + func (_m *IReporter) SetErrFn(efn func(error)) + func (_m *IReporter) SetHealth(state health.State, message string) + func (_m *IReporter) SetStdOutFallback(b bool) + func (_m *IReporter) SetTopic(topic string) + func (_m *IReporter) StartIntervalReporting(interval time.Duration) + func (_m *IReporter) Stop() error + func (_m *IReporter) StopWithFinalState(final health.State, msg string) error + type Signal struct + func (_m *Signal) RawReport(_a0 []byte) error + func (_m *Signal) Report(_a0 health.Event, _a1 interface{}) error
Go to main page