Documentation
¶
Index ¶
- type MockIPubSubEventProcessor
- func (_m *MockIPubSubEventProcessor) EXPECT() *MockIPubSubEventProcessor_Expecter
- func (_mock *MockIPubSubEventProcessor) EmitEvent(topic string, payload any) error
- func (_mock *MockIPubSubEventProcessor) EmitEventMessage(topic string, payload *message.Message) error
- func (_mock *MockIPubSubEventProcessor) RegisterSubscriberHandlers() error
- func (_mock *MockIPubSubEventProcessor) Run(ctx context.Context) error
- type MockIPubSubEventProcessor_EmitEventMessage_Call
- func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) Return(err error) *MockIPubSubEventProcessor_EmitEventMessage_Call
- func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) Run(run func(topic string, payload *message.Message)) *MockIPubSubEventProcessor_EmitEventMessage_Call
- func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) RunAndReturn(run func(topic string, payload *message.Message) error) *MockIPubSubEventProcessor_EmitEventMessage_Call
- type MockIPubSubEventProcessor_EmitEvent_Call
- func (_c *MockIPubSubEventProcessor_EmitEvent_Call) Return(err error) *MockIPubSubEventProcessor_EmitEvent_Call
- func (_c *MockIPubSubEventProcessor_EmitEvent_Call) Run(run func(topic string, payload any)) *MockIPubSubEventProcessor_EmitEvent_Call
- func (_c *MockIPubSubEventProcessor_EmitEvent_Call) RunAndReturn(run func(topic string, payload any) error) *MockIPubSubEventProcessor_EmitEvent_Call
- type MockIPubSubEventProcessor_Expecter
- func (_e *MockIPubSubEventProcessor_Expecter) EmitEvent(topic any, payload any) *MockIPubSubEventProcessor_EmitEvent_Call
- func (_e *MockIPubSubEventProcessor_Expecter) EmitEventMessage(topic any, payload any) *MockIPubSubEventProcessor_EmitEventMessage_Call
- func (_e *MockIPubSubEventProcessor_Expecter) RegisterSubscriberHandlers() *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
- func (_e *MockIPubSubEventProcessor_Expecter) Run(ctx any) *MockIPubSubEventProcessor_Run_Call
- type MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
- func (_c *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) Return(err error) *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
- func (_c *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) Run(run func()) *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
- func (_c *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) RunAndReturn(run func() error) *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
- type MockIPubSubEventProcessor_Run_Call
- func (_c *MockIPubSubEventProcessor_Run_Call) Return(err error) *MockIPubSubEventProcessor_Run_Call
- func (_c *MockIPubSubEventProcessor_Run_Call) Run(run func(ctx context.Context)) *MockIPubSubEventProcessor_Run_Call
- func (_c *MockIPubSubEventProcessor_Run_Call) RunAndReturn(run func(ctx context.Context) error) *MockIPubSubEventProcessor_Run_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIPubSubEventProcessor ¶
MockIPubSubEventProcessor is an autogenerated mock type for the IPubSubEventProcessor type
func NewMockIPubSubEventProcessor ¶
func NewMockIPubSubEventProcessor(t interface {
mock.TestingT
Cleanup(func())
}) *MockIPubSubEventProcessor
NewMockIPubSubEventProcessor creates a new instance of MockIPubSubEventProcessor. 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 (*MockIPubSubEventProcessor) EXPECT ¶
func (_m *MockIPubSubEventProcessor) EXPECT() *MockIPubSubEventProcessor_Expecter
func (*MockIPubSubEventProcessor) EmitEvent ¶
func (_mock *MockIPubSubEventProcessor) EmitEvent(topic string, payload any) error
EmitEvent provides a mock function for the type MockIPubSubEventProcessor
func (*MockIPubSubEventProcessor) EmitEventMessage ¶
func (_mock *MockIPubSubEventProcessor) EmitEventMessage(topic string, payload *message.Message) error
EmitEventMessage provides a mock function for the type MockIPubSubEventProcessor
func (*MockIPubSubEventProcessor) RegisterSubscriberHandlers ¶
func (_mock *MockIPubSubEventProcessor) RegisterSubscriberHandlers() error
RegisterSubscriberHandlers provides a mock function for the type MockIPubSubEventProcessor
type MockIPubSubEventProcessor_EmitEventMessage_Call ¶
MockIPubSubEventProcessor_EmitEventMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EmitEventMessage'
func (*MockIPubSubEventProcessor_EmitEventMessage_Call) Return ¶
func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) Return(err error) *MockIPubSubEventProcessor_EmitEventMessage_Call
func (*MockIPubSubEventProcessor_EmitEventMessage_Call) Run ¶
func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) Run(run func(topic string, payload *message.Message)) *MockIPubSubEventProcessor_EmitEventMessage_Call
func (*MockIPubSubEventProcessor_EmitEventMessage_Call) RunAndReturn ¶
func (_c *MockIPubSubEventProcessor_EmitEventMessage_Call) RunAndReturn(run func(topic string, payload *message.Message) error) *MockIPubSubEventProcessor_EmitEventMessage_Call
type MockIPubSubEventProcessor_EmitEvent_Call ¶
MockIPubSubEventProcessor_EmitEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EmitEvent'
func (*MockIPubSubEventProcessor_EmitEvent_Call) Return ¶
func (_c *MockIPubSubEventProcessor_EmitEvent_Call) Return(err error) *MockIPubSubEventProcessor_EmitEvent_Call
func (*MockIPubSubEventProcessor_EmitEvent_Call) Run ¶
func (_c *MockIPubSubEventProcessor_EmitEvent_Call) Run(run func(topic string, payload any)) *MockIPubSubEventProcessor_EmitEvent_Call
func (*MockIPubSubEventProcessor_EmitEvent_Call) RunAndReturn ¶
func (_c *MockIPubSubEventProcessor_EmitEvent_Call) RunAndReturn(run func(topic string, payload any) error) *MockIPubSubEventProcessor_EmitEvent_Call
type MockIPubSubEventProcessor_Expecter ¶
type MockIPubSubEventProcessor_Expecter struct {
// contains filtered or unexported fields
}
func (*MockIPubSubEventProcessor_Expecter) EmitEvent ¶
func (_e *MockIPubSubEventProcessor_Expecter) EmitEvent(topic any, payload any) *MockIPubSubEventProcessor_EmitEvent_Call
EmitEvent is a helper method to define mock.On call
- topic string
- payload any
func (*MockIPubSubEventProcessor_Expecter) EmitEventMessage ¶
func (_e *MockIPubSubEventProcessor_Expecter) EmitEventMessage(topic any, payload any) *MockIPubSubEventProcessor_EmitEventMessage_Call
EmitEventMessage is a helper method to define mock.On call
- topic string
- payload *message.Message
func (*MockIPubSubEventProcessor_Expecter) RegisterSubscriberHandlers ¶
func (_e *MockIPubSubEventProcessor_Expecter) RegisterSubscriberHandlers() *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
RegisterSubscriberHandlers is a helper method to define mock.On call
func (*MockIPubSubEventProcessor_Expecter) Run ¶
func (_e *MockIPubSubEventProcessor_Expecter) Run(ctx any) *MockIPubSubEventProcessor_Run_Call
Run is a helper method to define mock.On call
- ctx context.Context
type MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call ¶
MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterSubscriberHandlers'
func (*MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) Run ¶
func (_c *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) Run(run func()) *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
func (*MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) RunAndReturn ¶
func (_c *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call) RunAndReturn(run func() error) *MockIPubSubEventProcessor_RegisterSubscriberHandlers_Call
type MockIPubSubEventProcessor_Run_Call ¶
MockIPubSubEventProcessor_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'
func (*MockIPubSubEventProcessor_Run_Call) Return ¶
func (_c *MockIPubSubEventProcessor_Run_Call) Return(err error) *MockIPubSubEventProcessor_Run_Call
func (*MockIPubSubEventProcessor_Run_Call) Run ¶
func (_c *MockIPubSubEventProcessor_Run_Call) Run(run func(ctx context.Context)) *MockIPubSubEventProcessor_Run_Call
func (*MockIPubSubEventProcessor_Run_Call) RunAndReturn ¶
func (_c *MockIPubSubEventProcessor_Run_Call) RunAndReturn(run func(ctx context.Context) error) *MockIPubSubEventProcessor_Run_Call