Documentation
¶
Overview ¶
Package messaging is a generated GoMock package.
Package messaging is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelBuilderFunc ¶
type ErrorHandler ¶
type ErrorHandlerFunc ¶
func (ErrorHandlerFunc) HandleError ¶
func (f ErrorHandlerFunc) HandleError(ctx context.Context, err error)
type HandlerFunc ¶
func (HandlerFunc) HandleMessage ¶
type LogErrorHandler ¶
type LogErrorHandler struct {
// contains filtered or unexported fields
}
func NewLogErrorHandler ¶
func NewLogErrorHandler(logger log.Logger) *LogErrorHandler
func (*LogErrorHandler) HandleError ¶
func (h *LogErrorHandler) HandleError(ctx context.Context, err error)
type MockHandler ¶
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface
func NewMockHandler ¶
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance
func (*MockHandler) EXPECT ¶
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHandler) HandleMessage ¶
HandleMessage mocks base method
type MockHandlerMockRecorder ¶
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler
func (*MockHandlerMockRecorder) HandleMessage ¶
func (mr *MockHandlerMockRecorder) HandleMessage(ctx, h, message interface{}) *gomock.Call
HandleMessage indicates an expected call of HandleMessage
type MockReceiver ¶
type MockReceiver struct {
// contains filtered or unexported fields
}
MockReceiver is a mock of Receiver interface
func NewMockReceiver ¶
func NewMockReceiver(ctrl *gomock.Controller) *MockReceiver
NewMockReceiver creates a new mock instance
func (*MockReceiver) Channels ¶
func (m *MockReceiver) Channels() []string
Channels mocks base method
func (*MockReceiver) EXPECT ¶
func (m *MockReceiver) EXPECT() *MockReceiverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockReceiverMockRecorder ¶
type MockReceiverMockRecorder struct {
// contains filtered or unexported fields
}
MockReceiverMockRecorder is the mock recorder for MockReceiver
func (*MockReceiverMockRecorder) Channels ¶
func (mr *MockReceiverMockRecorder) Channels() *gomock.Call
Channels indicates an expected call of Channels
func (*MockReceiverMockRecorder) Close ¶
func (mr *MockReceiverMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockReceiverMockRecorder) Receive ¶
func (mr *MockReceiverMockRecorder) Receive(ctx, channel, h interface{}) *gomock.Call
Receive indicates an expected call of Receive
func (*MockReceiverMockRecorder) Suspend ¶
func (mr *MockReceiverMockRecorder) Suspend(ctx, channel interface{}) *gomock.Call
Suspend indicates an expected call of Suspend
type MockSender ¶
type MockSender struct {
// contains filtered or unexported fields
}
MockSender is a mock of Sender interface
func NewMockSender ¶
func NewMockSender(ctrl *gomock.Controller) *MockSender
NewMockSender creates a new mock instance
func (*MockSender) EXPECT ¶
func (m *MockSender) EXPECT() *MockSenderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockSenderMockRecorder ¶
type MockSenderMockRecorder struct {
// contains filtered or unexported fields
}
MockSenderMockRecorder is the mock recorder for MockSender
func (*MockSenderMockRecorder) Close ¶
func (mr *MockSenderMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockSenderMockRecorder) Send ¶
func (mr *MockSenderMockRecorder) Send(ctx, channel, h, route, message interface{}) *gomock.Call
Send indicates an expected call of Send
Source Files