Documentation
¶
Index ¶
- type MockAmqpService
- func (_m *MockAmqpService) Connect() error
- func (_m *MockAmqpService) EXPECT() *_MockAmqpServiceRecorder
- func (_m *MockAmqpService) Emit(exchangeKey string, payload []byte) error
- func (_m *MockAmqpService) On(queueName string, exchangeKey string, callback func([]byte) error) error
- func (_m *MockAmqpService) Shutdown() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAmqpService ¶
type MockAmqpService struct {
// contains filtered or unexported fields
}
Mock of AmqpService interface
func NewMockAmqpService ¶
func NewMockAmqpService(ctrl *gomock.Controller) *MockAmqpService
func (*MockAmqpService) Connect ¶
func (_m *MockAmqpService) Connect() error
func (*MockAmqpService) EXPECT ¶
func (_m *MockAmqpService) EXPECT() *_MockAmqpServiceRecorder
func (*MockAmqpService) Emit ¶
func (_m *MockAmqpService) Emit(exchangeKey string, payload []byte) error
func (*MockAmqpService) Shutdown ¶
func (_m *MockAmqpService) Shutdown() error
Source Files
Click to show internal directories.
Click to hide internal directories.