mocks

Documentation

Index

• type MessageProcessor
  • func NewMessageProcessor(t mockConstructorTestingTNewMessageProcessor) *MessageProcessor
  • func (_m *MessageProcessor) EXPECT() *MessageProcessor_Expecter
  • func (_m *MessageProcessor) ProcessMessage(ctx context.Context, message *funcie.MessageBase[json.RawMessage]) (*funcie.ResponseBase[json.RawMessage], error)
• type MessageProcessor_Expecter
  • func (_e *MessageProcessor_Expecter) ProcessMessage(ctx interface{}, message interface{}) *MessageProcessor_ProcessMessage_Call
• type MessageProcessor_ProcessMessage_Call
  • func (_c *MessageProcessor_ProcessMessage_Call) Return(_a0 *funcie.ResponseBase[json.RawMessage], _a1 error) *MessageProcessor_ProcessMessage_Call
  • func (_c *MessageProcessor_ProcessMessage_Call) Run(run func(ctx context.Context, message *funcie.MessageBase[json.RawMessage])) *MessageProcessor_ProcessMessage_Call
  • func (_c *MessageProcessor_ProcessMessage_Call) RunAndReturn(...) *MessageProcessor_ProcessMessage_Call

Types

type MessageProcessor

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor

func NewMessageProcessor(t mockConstructorTestingTNewMessageProcessor) *MessageProcessor

NewMessageProcessor creates a new instance of MessageProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MessageProcessor) EXPECT

func (_m *MessageProcessor) EXPECT() *MessageProcessor_Expecter

func (*MessageProcessor) ProcessMessage

func (_m *MessageProcessor) ProcessMessage(ctx context.Context, message *funcie.MessageBase[json.RawMessage]) (*funcie.ResponseBase[json.RawMessage], error)

ProcessMessage provides a mock function with given fields: ctx, message

type MessageProcessor_Expecter

type MessageProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*MessageProcessor_Expecter) ProcessMessage

func (_e *MessageProcessor_Expecter) ProcessMessage(ctx interface{}, message interface{}) *MessageProcessor_ProcessMessage_Call

ProcessMessage is a helper method to define mock.On call

• ctx context.Context
• message *funcie.MessageBase[json.RawMessage]

type MessageProcessor_ProcessMessage_Call

type MessageProcessor_ProcessMessage_Call struct {
	*mock.Call
}

MessageProcessor_ProcessMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessMessage'

func (*MessageProcessor_ProcessMessage_Call) Return

func (_c *MessageProcessor_ProcessMessage_Call) Return(_a0 *funcie.ResponseBase[json.RawMessage], _a1 error) *MessageProcessor_ProcessMessage_Call

func (*MessageProcessor_ProcessMessage_Call) Run

func (_c *MessageProcessor_ProcessMessage_Call) Run(run func(ctx context.Context, message *funcie.MessageBase[json.RawMessage])) *MessageProcessor_ProcessMessage_Call

func (*MessageProcessor_ProcessMessage_Call) RunAndReturn

func (_c *MessageProcessor_ProcessMessage_Call) RunAndReturn(run func(context.Context, *funcie.MessageBase[json.RawMessage]) (*funcie.ResponseBase[json.RawMessage], error)) *MessageProcessor_ProcessMessage_Call