Documentation
¶
Overview ¶
Package eventplatformimpl contains the logic for forwarding events to the event platform
Package eventplatformimpl is a generated GoMock package.
Index ¶
- func Diagnose() []diagnosis.Diagnosis
- func Module() fxutil.Module
- func NewNoopEventPlatformForwarder(hostname hostnameinterface.Component) eventplatform.Forwarder
- type MockEventPlatformForwarder
- func (m *MockEventPlatformForwarder) EXPECT() *MockEventPlatformForwarderMockRecorder
- func (m *MockEventPlatformForwarder) Purge() map[string][]*message.Message
- func (m *MockEventPlatformForwarder) SendEventPlatformEvent(e *message.Message, eventType string) error
- func (m *MockEventPlatformForwarder) SendEventPlatformEventBlocking(e *message.Message, eventType string) error
- func (m *MockEventPlatformForwarder) Start()
- func (m *MockEventPlatformForwarder) Stop()
- type MockEventPlatformForwarderMockRecorder
- func (mr *MockEventPlatformForwarderMockRecorder) Purge() *gomock.Call
- func (mr *MockEventPlatformForwarderMockRecorder) SendEventPlatformEvent(e, eventType interface{}) *gomock.Call
- func (mr *MockEventPlatformForwarderMockRecorder) SendEventPlatformEventBlocking(e, eventType interface{}) *gomock.Call
- func (mr *MockEventPlatformForwarderMockRecorder) Start() *gomock.Call
- func (mr *MockEventPlatformForwarderMockRecorder) Stop() *gomock.Call
- type Params
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Diagnose ¶
Diagnose enumerates known epforwarder pipelines and endpoints to test each of them connectivity
func NewNoopEventPlatformForwarder ¶
func NewNoopEventPlatformForwarder(hostname hostnameinterface.Component) eventplatform.Forwarder
NewNoopEventPlatformForwarder returns the standard event platform forwarder with sending disabled, meaning events will build up in each pipeline channel without being forwarded to the intake
Types ¶
type MockEventPlatformForwarder ¶
type MockEventPlatformForwarder struct {
// contains filtered or unexported fields
}
MockEventPlatformForwarder is a mock of EventPlatformForwarder interface.
func NewMockEventPlatformForwarder ¶
func NewMockEventPlatformForwarder(ctrl *gomock.Controller) *MockEventPlatformForwarder
NewMockEventPlatformForwarder creates a new mock instance.
func (*MockEventPlatformForwarder) EXPECT ¶
func (m *MockEventPlatformForwarder) EXPECT() *MockEventPlatformForwarderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventPlatformForwarder) Purge ¶
func (m *MockEventPlatformForwarder) Purge() map[string][]*message.Message
Purge mocks base method.
func (*MockEventPlatformForwarder) SendEventPlatformEvent ¶
func (m *MockEventPlatformForwarder) SendEventPlatformEvent(e *message.Message, eventType string) error
SendEventPlatformEvent mocks base method.
func (*MockEventPlatformForwarder) SendEventPlatformEventBlocking ¶
func (m *MockEventPlatformForwarder) SendEventPlatformEventBlocking(e *message.Message, eventType string) error
SendEventPlatformEventBlocking mocks base method.
func (*MockEventPlatformForwarder) Start ¶
func (m *MockEventPlatformForwarder) Start()
Start mocks base method.
func (*MockEventPlatformForwarder) Stop ¶
func (m *MockEventPlatformForwarder) Stop()
Stop mocks base method.
type MockEventPlatformForwarderMockRecorder ¶
type MockEventPlatformForwarderMockRecorder struct {
// contains filtered or unexported fields
}
MockEventPlatformForwarderMockRecorder is the mock recorder for MockEventPlatformForwarder.
func (*MockEventPlatformForwarderMockRecorder) Purge ¶
func (mr *MockEventPlatformForwarderMockRecorder) Purge() *gomock.Call
Purge indicates an expected call of Purge.
func (*MockEventPlatformForwarderMockRecorder) SendEventPlatformEvent ¶
func (mr *MockEventPlatformForwarderMockRecorder) SendEventPlatformEvent(e, eventType interface{}) *gomock.Call
SendEventPlatformEvent indicates an expected call of SendEventPlatformEvent.
func (*MockEventPlatformForwarderMockRecorder) SendEventPlatformEventBlocking ¶
func (mr *MockEventPlatformForwarderMockRecorder) SendEventPlatformEventBlocking(e, eventType interface{}) *gomock.Call
SendEventPlatformEventBlocking indicates an expected call of SendEventPlatformEventBlocking.
func (*MockEventPlatformForwarderMockRecorder) Start ¶
func (mr *MockEventPlatformForwarderMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockEventPlatformForwarderMockRecorder) Stop ¶
func (mr *MockEventPlatformForwarderMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type Params ¶
Params defines the parameters for the event platform forwarder.
func NewDefaultParams ¶
func NewDefaultParams() Params
NewDefaultParams returns the default parameters for the event platform forwarder.
func NewDisabledParams ¶
func NewDisabledParams() Params
NewDisabledParams returns the disabled parameters for the event platform forwarder.
Source Files