Documentation
¶
Overview ¶
Package mock_amqp is a generated GoMock package.
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 amqp0.Table) (<-chan amqp0.Delivery, error)
- func (m *MockChannel) EXPECT() *MockChannelMockRecorder
- func (m *MockChannel) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp0.Table) error
- func (m *MockChannel) Nack(arg0 uint64, arg1, arg2 bool) error
- func (m *MockChannel) Publish(arg0, arg1 string, arg2, arg3 bool, arg4 amqp0.Publishing) error
- func (m *MockChannel) Qos(arg0, arg1 int, arg2 bool) error
- func (m *MockChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp0.Table) error
- func (m *MockChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp0.Table) (amqp0.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) Publish(arg0, arg1, arg2, arg3, arg4 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) 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 amqp0.Table) (<-chan amqp0.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 amqp0.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) Publish ¶
func (m *MockChannel) Publish(arg0, arg1 string, arg2, arg3 bool, arg4 amqp0.Publishing) error
Publish 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 amqp0.Table) (amqp0.Queue, error)
QueueDeclare 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) Publish ¶
func (mr *MockChannelMockRecorder) Publish(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Publish indicates an expected call of Publish
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) 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) Publish ¶
func (m *MockPublisher) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
Publish mocks base method
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher
func (*MockPublisherMockRecorder) Publish ¶
func (mr *MockPublisherMockRecorder) Publish(exchange, key, mandatory, immediate, msg interface{}) *gomock.Call
Publish indicates an expected call of Publish
Source Files