Documentation
¶
Overview ¶
Package mock_consumer is a generated GoMock package.
Index ¶
- type MockAMQPChannel
- func (m *MockAMQPChannel) Cancel(arg0 string, arg1 bool) error
- func (m *MockAMQPChannel) Close() error
- func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.Delivery, error)
- func (m *MockAMQPChannel) EXPECT() *MockAMQPChannelMockRecorder
- func (m *MockAMQPChannel) NotifyCancel(arg0 chan string) chan string
- func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp091.Error) chan *amqp091.Error
- func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error
- func (m *MockAMQPChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp091.Table) error
- func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.Queue, error)
- type MockAMQPChannelMockRecorder
- func (mr *MockAMQPChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call
- 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) Cancel ¶ added in v1.2.1
func (m *MockAMQPChannel) Cancel(arg0 string, arg1 bool) error
Cancel mocks base method.
func (*MockAMQPChannel) Consume ¶
func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.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 *amqp091.Error) chan *amqp091.Error
NotifyClose mocks base method.
func (*MockAMQPChannel) Qos ¶ added in v0.16.2
func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error
Qos mocks base method.
func (*MockAMQPChannel) QueueDeclare ¶ added in v0.16.0
func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.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) Cancel ¶ added in v1.2.1
func (mr *MockAMQPChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call
Cancel indicates an expected call of Cancel.
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 ¶ added in v0.16.2
func (mr *MockAMQPChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
Qos indicates an expected call of Qos.
func (*MockAMQPChannelMockRecorder) QueueBind ¶ added in v0.16.0
func (mr *MockAMQPChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
QueueBind indicates an expected call of QueueBind.
func (*MockAMQPChannelMockRecorder) QueueDeclare ¶ added in v0.16.0
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