Documentation
¶
Index ¶
- Variables
- func New(log *logp.Logger, name string, reloader Reloader, validator Validator, ...) beat.Beater
- type BeaterUnhealthyError
- type Listener
- type MockReloader
- type MockReloader_Channel_Call
- type MockReloader_Expecter
- type MockReloader_Stop_Call
- type MockValidator
- type MockValidator_Expecter
- type MockValidator_Validate_Call
- type Reloader
- type Validator
Constants ¶
This section is empty.
Variables ¶
var ErrorGracefulExit = beat.GracefulExit
ErrorGracefulExit is used when the launcher stops before shutdownGracePeriod, after waiting for the beater to stop
var ErrorStopSignal = errors.New("stop beater")
ErrorStopSignal is used to indicate we got a stop signal
var ErrorTimeoutExit = errors.New("exit after timeout")
ErrorTimeoutExit is used when the launcher stops after shutdownGracePeriod, without waiting for the beater to stop
Functions ¶
Types ¶
type BeaterUnhealthyError ¶
type BeaterUnhealthyError struct {
// contains filtered or unexported fields
}
BeaterUnhealthyError error is an error that is designed to have an information that can help to end user to operate cloudbeat health issues. For example, when a cloudbeat configuration is invalid, the error will include more information about what is missing/expected and might have links to external sources as well
func NewUnhealthyError ¶
func NewUnhealthyError(msg string) BeaterUnhealthyError
func (BeaterUnhealthyError) Error ¶
func (c BeaterUnhealthyError) Error() string
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
func NewListener ¶
type MockReloader ¶
MockReloader is an autogenerated mock type for the Reloader type
func NewMockReloader ¶
func NewMockReloader(t interface {
mock.TestingT
Cleanup(func())
}) *MockReloader
NewMockReloader creates a new instance of MockReloader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockReloader) Channel ¶
func (_m *MockReloader) Channel() <-chan *config.C
Channel provides a mock function with given fields:
func (*MockReloader) EXPECT ¶
func (_m *MockReloader) EXPECT() *MockReloader_Expecter
func (*MockReloader) Stop ¶
func (_m *MockReloader) Stop()
Stop provides a mock function with given fields:
type MockReloader_Channel_Call ¶
MockReloader_Channel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channel'
func (*MockReloader_Channel_Call) Return ¶
func (_c *MockReloader_Channel_Call) Return(_a0 <-chan *config.C) *MockReloader_Channel_Call
func (*MockReloader_Channel_Call) Run ¶
func (_c *MockReloader_Channel_Call) Run(run func()) *MockReloader_Channel_Call
func (*MockReloader_Channel_Call) RunAndReturn ¶
func (_c *MockReloader_Channel_Call) RunAndReturn(run func() <-chan *config.C) *MockReloader_Channel_Call
type MockReloader_Expecter ¶
type MockReloader_Expecter struct {
// contains filtered or unexported fields
}
func (*MockReloader_Expecter) Channel ¶
func (_e *MockReloader_Expecter) Channel() *MockReloader_Channel_Call
Channel is a helper method to define mock.On call
func (*MockReloader_Expecter) Stop ¶
func (_e *MockReloader_Expecter) Stop() *MockReloader_Stop_Call
Stop is a helper method to define mock.On call
type MockReloader_Stop_Call ¶
MockReloader_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*MockReloader_Stop_Call) Return ¶
func (_c *MockReloader_Stop_Call) Return() *MockReloader_Stop_Call
func (*MockReloader_Stop_Call) Run ¶
func (_c *MockReloader_Stop_Call) Run(run func()) *MockReloader_Stop_Call
func (*MockReloader_Stop_Call) RunAndReturn ¶
func (_c *MockReloader_Stop_Call) RunAndReturn(run func()) *MockReloader_Stop_Call
type MockValidator ¶
MockValidator is an autogenerated mock type for the Validator type
func NewMockValidator ¶
func NewMockValidator(t interface {
mock.TestingT
Cleanup(func())
}) *MockValidator
NewMockValidator creates a new instance of MockValidator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockValidator) EXPECT ¶
func (_m *MockValidator) EXPECT() *MockValidator_Expecter
type MockValidator_Expecter ¶
type MockValidator_Expecter struct {
// contains filtered or unexported fields
}
func (*MockValidator_Expecter) Validate ¶
func (_e *MockValidator_Expecter) Validate(_a0 interface{}) *MockValidator_Validate_Call
Validate is a helper method to define mock.On call
- _a0 *config.C
type MockValidator_Validate_Call ¶
MockValidator_Validate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Validate'
func (*MockValidator_Validate_Call) Return ¶
func (_c *MockValidator_Validate_Call) Return(_a0 error) *MockValidator_Validate_Call
func (*MockValidator_Validate_Call) Run ¶
func (_c *MockValidator_Validate_Call) Run(run func(_a0 *config.C)) *MockValidator_Validate_Call
func (*MockValidator_Validate_Call) RunAndReturn ¶
func (_c *MockValidator_Validate_Call) RunAndReturn(run func(*config.C) error) *MockValidator_Validate_Call
Source Files