Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockAcknowledger
- type MockAcknowledgerMockRecorder
- type MockChannel
- func (m *MockChannel) Close() error
- func (m *MockChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
- func (m *MockChannel) EXPECT() *MockChannelMockRecorder
- func (m *MockChannel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
- func (m *MockChannel) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
- func (m *MockChannel) QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
- func (m *MockChannel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
- type MockChannelMockRecorder
- func (mr *MockChannelMockRecorder) Close() *gomock.Call
- func (mr *MockChannelMockRecorder) Consume(queue, consumer, autoAck, exclusive, noLocal, noWait, args interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeDeclare(name, kind, durable, autoDelete, internal, noWait, args interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Publish(exchange, key, mandatory, immediate, msg interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueBind(name, key, exchange, noWait, args interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueDeclare(name, durable, autoDelete, exclusive, noWait, args interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAcknowledger ¶
type MockAcknowledger struct {
// contains filtered or unexported fields
}
MockAcknowledger is a mock of Acknowledger interface.
func NewMockAcknowledger ¶
func NewMockAcknowledger(ctrl *gomock.Controller) *MockAcknowledger
NewMockAcknowledger creates a new mock instance.
func (*MockAcknowledger) Ack ¶
func (m *MockAcknowledger) Ack(arg0 uint64, arg1 bool) error
Ack mocks base method.
func (*MockAcknowledger) EXPECT ¶
func (m *MockAcknowledger) EXPECT() *MockAcknowledgerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockAcknowledgerMockRecorder ¶
type MockAcknowledgerMockRecorder struct {
// contains filtered or unexported fields
}
MockAcknowledgerMockRecorder is the mock recorder for MockAcknowledger.
func (*MockAcknowledgerMockRecorder) Ack ¶
func (mr *MockAcknowledgerMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call
Ack indicates an expected call of Ack.
func (*MockAcknowledgerMockRecorder) Nack ¶
func (mr *MockAcknowledgerMockRecorder) Nack(arg0, arg1, arg2 interface{}) *gomock.Call
Nack indicates an expected call of Nack.
func (*MockAcknowledgerMockRecorder) Reject ¶
func (mr *MockAcknowledgerMockRecorder) Reject(arg0, arg1 interface{}) *gomock.Call
Reject indicates an expected call of Reject.
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) Consume ¶
func (m *MockChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.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(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
ExchangeDeclare mocks base method.
func (*MockChannel) Publish ¶
func (m *MockChannel) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
Publish mocks base method.
func (*MockChannel) QueueDeclare ¶
func (m *MockChannel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
QueueDeclare mocks base method.
type MockChannelMockRecorder ¶
type MockChannelMockRecorder struct {
// contains filtered or unexported fields
}
MockChannelMockRecorder is the mock recorder for MockChannel.
func (*MockChannelMockRecorder) Close ¶
func (mr *MockChannelMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockChannelMockRecorder) Consume ¶
func (mr *MockChannelMockRecorder) Consume(queue, consumer, autoAck, exclusive, noLocal, noWait, args interface{}) *gomock.Call
Consume indicates an expected call of Consume.
func (*MockChannelMockRecorder) ExchangeDeclare ¶
func (mr *MockChannelMockRecorder) ExchangeDeclare(name, kind, durable, autoDelete, internal, noWait, args interface{}) *gomock.Call
ExchangeDeclare indicates an expected call of ExchangeDeclare.
func (*MockChannelMockRecorder) Publish ¶
func (mr *MockChannelMockRecorder) Publish(exchange, key, mandatory, immediate, msg interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockChannelMockRecorder) QueueBind ¶
func (mr *MockChannelMockRecorder) QueueBind(name, key, exchange, noWait, args interface{}) *gomock.Call
QueueBind indicates an expected call of QueueBind.
func (*MockChannelMockRecorder) QueueDeclare ¶
func (mr *MockChannelMockRecorder) QueueDeclare(name, durable, autoDelete, exclusive, noWait, args interface{}) *gomock.Call
QueueDeclare indicates an expected call of QueueDeclare.
Source Files