mocks

Documentation

Index

• type MockAmqpService
  • func NewMockAmqpService(ctrl *gomock.Controller) *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

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) On

func (_m *MockAmqpService) On(queueName string, exchangeKey string, callback func([]byte) error) error

func (*MockAmqpService) Shutdown

func (_m *MockAmqpService) Shutdown() error