eventplatformimpl

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(params Params) fxutil.Module
• func NewNoopEventPlatformForwarder(hostname hostnameinterface.Component) eventplatform.Forwarder
• type MockEventPlatformForwarder
  • func NewMockEventPlatformForwarder(ctrl *gomock.Controller) *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
  • func NewDefaultParams() Params
  • func NewDisabledParams() Params

Functions

func Diagnose

func Diagnose() []diagnosis.Diagnosis

Diagnose enumerates known epforwarder pipelines and endpoints to test each of them connectivity

func Module

func Module(params Params) fxutil.Module

Module defines the fx options for this component.

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

type Params struct {
	UseNoopEventPlatformForwarder bool
	UseEventPlatformForwarder     bool
}

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.