Documentation ¶
Index ¶
- type IReporter
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IReporter ¶
IReporter is an autogenerated mock type for the IReporter type
func (*IReporter) AddHostnameSuffix ¶
AddHostnameSuffix provides a mock function with given fields: _a0
func (*IReporter) ClearAll ¶
func (_m *IReporter) ClearAll()
ClearAll provides a mock function with given fields:
func (*IReporter) ClearStatFns ¶
func (_m *IReporter) ClearStatFns()
ClearStatFns provides a mock function with given fields:
func (*IReporter) ClearStats ¶
func (_m *IReporter) ClearStats()
ClearStats provides a mock function with given fields:
func (*IReporter) GetKafkaLogWriter ¶
GetKafkaLogWriter provides a mock function with given fields:
func (*IReporter) HealthHandler ¶
func (_m *IReporter) HealthHandler(w http.ResponseWriter, req *http.Request)
HealthHandler provides a mock function with given fields: w, req
func (*IReporter) Initialize ¶
Initialize provides a mock function with given fields:
func (*IReporter) KafkaHealthy ¶
KafkaHealthy provides a mock function with given fields:
func (*IReporter) PersistStat ¶
PersistStat provides a mock function with given fields: key, val
func (*IReporter) RegisterStatFn ¶
RegisterStatFn provides a mock function with given fields: name, fn
func (*IReporter) ReportHealth ¶
func (_m *IReporter) ReportHealth()
ReportHealth provides a mock function with given fields:
func (*IReporter) SetStdOutFallback ¶
SetStdOutFallback provides a mock function with given fields: b
func (*IReporter) StartIntervalReporting ¶
StartIntervalReporting provides a mock function with given fields: interval