Documentation
¶
Overview ¶
Package mock_amqp is a generated GoMock package.
Index ¶
- type MockChannel
- func (m *MockChannel) Ack(arg0 uint64, arg1 bool) error
- func (m *MockChannel) Close() error
- func (m *MockChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.Delivery, error)
- func (m *MockChannel) EXPECT() *MockChannelMockRecorder
- func (m *MockChannel) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) error
- func (m *MockChannel) Nack(arg0 uint64, arg1, arg2 bool) error
- func (m *MockChannel) PublishWithContext(arg0 context.Context, arg1, arg2 string, arg3, arg4 bool, ...) error
- func (m *MockChannel) Qos(arg0, arg1 int, arg2 bool) error
- func (m *MockChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp091.Table) error
- func (m *MockChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.Queue, error)
- func (m *MockChannel) QueueInspect(arg0 string) (amqp091.Queue, error)
- func (m *MockChannel) QueuePurge(arg0 string, arg1 bool) (int, error)
- type MockChannelMockRecorder
- func (mr *MockChannelMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Close() *gomock.Call
- func (mr *MockChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeDeclare(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Nack(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) PublishWithContext(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueInspect(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueuePurge(arg0, arg1 interface{}) *gomock.Call
- type MockConnection
- type MockConnectionMockRecorder
- type MockPublisher
- type MockPublisherMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockChannel ¶
type MockChannel struct {
// contains filtered or unexported fields
}
MockChannel is a mock of Channel interface.
func NewMockChannel ¶
func NewMockChannel(ctrl *gomock.Controller) *MockChannel
NewMockChannel creates a new mock instance.
func (*MockChannel) Ack ¶
func (m *MockChannel) Ack(arg0 uint64, arg1 bool) error
Ack mocks base method.
func (*MockChannel) Consume ¶
func (m *MockChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.Delivery, error)
Consume mocks base method.
func (*MockChannel) EXPECT ¶
func (m *MockChannel) EXPECT() *MockChannelMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockChannel) ExchangeDeclare ¶
func (m *MockChannel) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) error
ExchangeDeclare mocks base method.
func (*MockChannel) Nack ¶
func (m *MockChannel) Nack(arg0 uint64, arg1, arg2 bool) error
Nack mocks base method.
func (*MockChannel) PublishWithContext ¶
func (m *MockChannel) PublishWithContext(arg0 context.Context, arg1, arg2 string, arg3, arg4 bool, arg5 amqp091.Publishing) error
PublishWithContext mocks base method.
func (*MockChannel) Qos ¶
func (m *MockChannel) Qos(arg0, arg1 int, arg2 bool) error
Qos mocks base method.
func (*MockChannel) QueueDeclare ¶
func (m *MockChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.Queue, error)
QueueDeclare mocks base method.
func (*MockChannel) QueueInspect ¶
func (m *MockChannel) QueueInspect(arg0 string) (amqp091.Queue, error)
QueueInspect mocks base method.
func (*MockChannel) QueuePurge ¶
func (m *MockChannel) QueuePurge(arg0 string, arg1 bool) (int, error)
QueuePurge mocks base method.
type MockChannelMockRecorder ¶
type MockChannelMockRecorder struct {
// contains filtered or unexported fields
}
MockChannelMockRecorder is the mock recorder for MockChannel.
func (*MockChannelMockRecorder) Ack ¶
func (mr *MockChannelMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call
Ack indicates an expected call of Ack.
func (*MockChannelMockRecorder) Close ¶
func (mr *MockChannelMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockChannelMockRecorder) Consume ¶
func (mr *MockChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
Consume indicates an expected call of Consume.
func (*MockChannelMockRecorder) ExchangeDeclare ¶
func (mr *MockChannelMockRecorder) ExchangeDeclare(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
ExchangeDeclare indicates an expected call of ExchangeDeclare.
func (*MockChannelMockRecorder) Nack ¶
func (mr *MockChannelMockRecorder) Nack(arg0, arg1, arg2 interface{}) *gomock.Call
Nack indicates an expected call of Nack.
func (*MockChannelMockRecorder) PublishWithContext ¶
func (mr *MockChannelMockRecorder) PublishWithContext(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
PublishWithContext indicates an expected call of PublishWithContext.
func (*MockChannelMockRecorder) Qos ¶
func (mr *MockChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
Qos indicates an expected call of Qos.
func (*MockChannelMockRecorder) QueueBind ¶
func (mr *MockChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
QueueBind indicates an expected call of QueueBind.
func (*MockChannelMockRecorder) QueueDeclare ¶
func (mr *MockChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
QueueDeclare indicates an expected call of QueueDeclare.
func (*MockChannelMockRecorder) QueueInspect ¶
func (mr *MockChannelMockRecorder) QueueInspect(arg0 interface{}) *gomock.Call
QueueInspect indicates an expected call of QueueInspect.
func (*MockChannelMockRecorder) QueuePurge ¶
func (mr *MockChannelMockRecorder) QueuePurge(arg0, arg1 interface{}) *gomock.Call
QueuePurge indicates an expected call of QueuePurge.
type MockConnection ¶
type MockConnection struct {
// contains filtered or unexported fields
}
MockConnection is a mock of Connection interface.
func NewMockConnection ¶
func NewMockConnection(ctrl *gomock.Controller) *MockConnection
NewMockConnection creates a new mock instance.
func (*MockConnection) Channel ¶
func (m *MockConnection) Channel() (amqp.Channel, error)
Channel mocks base method.
func (*MockConnection) EXPECT ¶
func (m *MockConnection) EXPECT() *MockConnectionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConnection) IsClosed ¶
func (m *MockConnection) IsClosed() bool
IsClosed mocks base method.
type MockConnectionMockRecorder ¶
type MockConnectionMockRecorder struct {
// contains filtered or unexported fields
}
MockConnectionMockRecorder is the mock recorder for MockConnection.
func (*MockConnectionMockRecorder) Channel ¶
func (mr *MockConnectionMockRecorder) Channel() *gomock.Call
Channel indicates an expected call of Channel.
func (*MockConnectionMockRecorder) Close ¶
func (mr *MockConnectionMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockConnectionMockRecorder) IsClosed ¶
func (mr *MockConnectionMockRecorder) IsClosed() *gomock.Call
IsClosed indicates an expected call of IsClosed.
type MockPublisher ¶
type MockPublisher struct {
// contains filtered or unexported fields
}
MockPublisher is a mock of Publisher interface.
func NewMockPublisher ¶
func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
NewMockPublisher creates a new mock instance.
func (*MockPublisher) EXPECT ¶
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPublisher) PublishWithContext ¶
func (m *MockPublisher) PublishWithContext(arg0 context.Context, arg1, arg2 string, arg3, arg4 bool, arg5 amqp091.Publishing) error
PublishWithContext mocks base method.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
func (*MockPublisherMockRecorder) PublishWithContext ¶
func (mr *MockPublisherMockRecorder) PublishWithContext(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
PublishWithContext indicates an expected call of PublishWithContext.
Source Files