Documentation
¶
Overview ¶
Package mock_consumer is a generated GoMock package.
Index ¶
- type MockAMQPChannel
- func (m *MockAMQPChannel) Close() error
- func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) (<-chan amqp.Delivery, error)
- func (m *MockAMQPChannel) EXPECT() *MockAMQPChannelMockRecorder
- func (m *MockAMQPChannel) NotifyCancel(arg0 chan string) chan string
- func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp.Error) chan *amqp.Error
- func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error
- func (m *MockAMQPChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp.Table) error
- func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp.Table) (amqp.Queue, error)
- type MockAMQPChannelMockRecorder
- func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- type MockAMQPConnection
- type MockAMQPConnectionMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAMQPChannel ¶
type MockAMQPChannel struct {
// contains filtered or unexported fields
}
MockAMQPChannel is a mock of AMQPChannel interface
func NewMockAMQPChannel ¶
func NewMockAMQPChannel(ctrl *gomock.Controller) *MockAMQPChannel
NewMockAMQPChannel creates a new mock instance
func (*MockAMQPChannel) Consume ¶
func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) (<-chan amqp.Delivery, error)
Consume mocks base method
func (*MockAMQPChannel) EXPECT ¶
func (m *MockAMQPChannel) EXPECT() *MockAMQPChannelMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAMQPChannel) NotifyCancel ¶
func (m *MockAMQPChannel) NotifyCancel(arg0 chan string) chan string
NotifyCancel mocks base method
func (*MockAMQPChannel) NotifyClose ¶
func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp.Error) chan *amqp.Error
NotifyClose mocks base method
func (*MockAMQPChannel) Qos ¶
func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error
Qos mocks base method
func (*MockAMQPChannel) QueueDeclare ¶
func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp.Table) (amqp.Queue, error)
QueueDeclare mocks base method
type MockAMQPChannelMockRecorder ¶
type MockAMQPChannelMockRecorder struct {
// contains filtered or unexported fields
}
MockAMQPChannelMockRecorder is the mock recorder for MockAMQPChannel
func (*MockAMQPChannelMockRecorder) Close ¶
func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockAMQPChannelMockRecorder) Consume ¶
func (mr *MockAMQPChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
Consume indicates an expected call of Consume
func (*MockAMQPChannelMockRecorder) NotifyCancel ¶
func (mr *MockAMQPChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call
NotifyCancel indicates an expected call of NotifyCancel
func (*MockAMQPChannelMockRecorder) NotifyClose ¶
func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
NotifyClose indicates an expected call of NotifyClose
func (*MockAMQPChannelMockRecorder) Qos ¶
func (mr *MockAMQPChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
Qos indicates an expected call of Qos
func (*MockAMQPChannelMockRecorder) QueueBind ¶
func (mr *MockAMQPChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
QueueBind indicates an expected call of QueueBind
func (*MockAMQPChannelMockRecorder) QueueDeclare ¶
func (mr *MockAMQPChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
QueueDeclare indicates an expected call of QueueDeclare
type MockAMQPConnection ¶
type MockAMQPConnection struct {
// contains filtered or unexported fields
}
MockAMQPConnection is a mock of AMQPConnection interface
func NewMockAMQPConnection ¶
func NewMockAMQPConnection(ctrl *gomock.Controller) *MockAMQPConnection
NewMockAMQPConnection creates a new mock instance
func (*MockAMQPConnection) EXPECT ¶
func (m *MockAMQPConnection) EXPECT() *MockAMQPConnectionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockAMQPConnectionMockRecorder ¶
type MockAMQPConnectionMockRecorder struct {
// contains filtered or unexported fields
}
MockAMQPConnectionMockRecorder is the mock recorder for MockAMQPConnection
Source Files