Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockChannel
- func (m *MockChannel) Ack(arg0 uint64, arg1 bool) error
- func (m *MockChannel) Cancel(arg0 string, arg1 bool) error
- func (m *MockChannel) Close() error
- func (m *MockChannel) Confirm(arg0 bool) error
- func (m *MockChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) (<-chan amqp.Delivery, error)
- func (m *MockChannel) EXPECT() *MockChannelMockRecorder
- func (m *MockChannel) ExchangeBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp.Table) error
- func (m *MockChannel) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) error
- func (m *MockChannel) ExchangeDeclarePassive(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) error
- func (m *MockChannel) ExchangeDelete(arg0 string, arg1, arg2 bool) error
- func (m *MockChannel) ExchangeUnbind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp.Table) error
- func (m *MockChannel) Flow(arg0 bool) error
- func (m *MockChannel) Get(arg0 string, arg1 bool) (amqp.Delivery, bool, error)
- func (m *MockChannel) Nack(arg0 uint64, arg1, arg2 bool) error
- func (m *MockChannel) NotifyCancel(arg0 chan string) chan string
- func (m *MockChannel) NotifyClose(arg0 chan *amqp.Error) chan *amqp.Error
- func (m *MockChannel) NotifyConfirm(arg0, arg1 chan uint64) (chan uint64, chan uint64)
- func (m *MockChannel) NotifyFlow(arg0 chan bool) chan bool
- func (m *MockChannel) NotifyPublish(arg0 chan amqp.Confirmation) chan amqp.Confirmation
- func (m *MockChannel) NotifyReturn(arg0 chan amqp.Return) chan amqp.Return
- func (m *MockChannel) Publish(arg0, arg1 string, arg2, arg3 bool, arg4 amqp.Publishing) error
- func (m *MockChannel) Qos(arg0, arg1 int, arg2 bool) error
- func (m *MockChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp.Table) error
- func (m *MockChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp.Table) (amqp.Queue, error)
- func (m *MockChannel) QueueDeclarePassive(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp.Table) (amqp.Queue, error)
- func (m *MockChannel) QueueDelete(arg0 string, arg1, arg2, arg3 bool) (int, error)
- func (m *MockChannel) QueueInspect(arg0 string) (amqp.Queue, error)
- func (m *MockChannel) QueuePurge(arg0 string, arg1 bool) (int, error)
- func (m *MockChannel) QueueUnbind(arg0, arg1, arg2 string, arg3 amqp.Table) error
- func (m *MockChannel) Recover(arg0 bool) error
- func (m *MockChannel) Reject(arg0 uint64, arg1 bool) error
- func (m *MockChannel) Tx() error
- func (m *MockChannel) TxCommit() error
- func (m *MockChannel) TxRollback() error
- type MockChannelMockRecorder
- func (mr *MockChannelMockRecorder) Ack(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Close() *gomock.Call
- func (mr *MockChannelMockRecorder) Confirm(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeDeclare(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeDeclarePassive(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeDelete(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) ExchangeUnbind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Flow(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Nack(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyConfirm(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyFlow(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyPublish(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) NotifyReturn(arg0 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) QueueDeclarePassive(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueDelete(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueInspect(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueuePurge(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) QueueUnbind(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Recover(arg0 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Reject(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockChannelMockRecorder) Tx() *gomock.Call
- func (mr *MockChannelMockRecorder) TxCommit() *gomock.Call
- func (mr *MockChannelMockRecorder) TxRollback() *gomock.Call
- type MockDialer
- type MockDialerMockRecorder
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) Cancel ¶
func (m *MockChannel) Cancel(arg0 string, arg1 bool) error
Cancel mocks base method
func (*MockChannel) Confirm ¶
func (m *MockChannel) Confirm(arg0 bool) error
Confirm mocks base method
func (*MockChannel) Consume ¶
func (m *MockChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 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) ExchangeBind ¶
ExchangeBind mocks base method
func (*MockChannel) ExchangeDeclare ¶
func (m *MockChannel) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) error
ExchangeDeclare mocks base method
func (*MockChannel) ExchangeDeclarePassive ¶
func (m *MockChannel) ExchangeDeclarePassive(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) error
ExchangeDeclarePassive mocks base method
func (*MockChannel) ExchangeDelete ¶
func (m *MockChannel) ExchangeDelete(arg0 string, arg1, arg2 bool) error
ExchangeDelete mocks base method
func (*MockChannel) ExchangeUnbind ¶
ExchangeUnbind mocks base method
func (*MockChannel) Nack ¶
func (m *MockChannel) Nack(arg0 uint64, arg1, arg2 bool) error
Nack mocks base method
func (*MockChannel) NotifyCancel ¶
func (m *MockChannel) NotifyCancel(arg0 chan string) chan string
NotifyCancel mocks base method
func (*MockChannel) NotifyClose ¶
func (m *MockChannel) NotifyClose(arg0 chan *amqp.Error) chan *amqp.Error
NotifyClose mocks base method
func (*MockChannel) NotifyConfirm ¶
func (m *MockChannel) NotifyConfirm(arg0, arg1 chan uint64) (chan uint64, chan uint64)
NotifyConfirm mocks base method
func (*MockChannel) NotifyFlow ¶
func (m *MockChannel) NotifyFlow(arg0 chan bool) chan bool
NotifyFlow mocks base method
func (*MockChannel) NotifyPublish ¶
func (m *MockChannel) NotifyPublish(arg0 chan amqp.Confirmation) chan amqp.Confirmation
NotifyPublish mocks base method
func (*MockChannel) NotifyReturn ¶
func (m *MockChannel) NotifyReturn(arg0 chan amqp.Return) chan amqp.Return
NotifyReturn mocks base method
func (*MockChannel) Publish ¶
func (m *MockChannel) Publish(arg0, arg1 string, arg2, arg3 bool, arg4 amqp.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 amqp.Table) (amqp.Queue, error)
QueueDeclare mocks base method
func (*MockChannel) QueueDeclarePassive ¶
func (m *MockChannel) QueueDeclarePassive(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp.Table) (amqp.Queue, error)
QueueDeclarePassive mocks base method
func (*MockChannel) QueueDelete ¶
func (m *MockChannel) QueueDelete(arg0 string, arg1, arg2, arg3 bool) (int, error)
QueueDelete mocks base method
func (*MockChannel) QueueInspect ¶
func (m *MockChannel) QueueInspect(arg0 string) (amqp.Queue, error)
QueueInspect mocks base method
func (*MockChannel) QueuePurge ¶
func (m *MockChannel) QueuePurge(arg0 string, arg1 bool) (int, error)
QueuePurge mocks base method
func (*MockChannel) QueueUnbind ¶
func (m *MockChannel) QueueUnbind(arg0, arg1, arg2 string, arg3 amqp.Table) error
QueueUnbind mocks base method
func (*MockChannel) Recover ¶
func (m *MockChannel) Recover(arg0 bool) error
Recover mocks base method
func (*MockChannel) Reject ¶
func (m *MockChannel) Reject(arg0 uint64, arg1 bool) error
Reject mocks base method
func (*MockChannel) TxRollback ¶
func (m *MockChannel) TxRollback() error
TxRollback 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) Cancel ¶
func (mr *MockChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call
Cancel indicates an expected call of Cancel
func (*MockChannelMockRecorder) Close ¶
func (mr *MockChannelMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockChannelMockRecorder) Confirm ¶
func (mr *MockChannelMockRecorder) Confirm(arg0 interface{}) *gomock.Call
Confirm indicates an expected call of Confirm
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) ExchangeBind ¶
func (mr *MockChannelMockRecorder) ExchangeBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
ExchangeBind indicates an expected call of ExchangeBind
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) ExchangeDeclarePassive ¶
func (mr *MockChannelMockRecorder) ExchangeDeclarePassive(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
ExchangeDeclarePassive indicates an expected call of ExchangeDeclarePassive
func (*MockChannelMockRecorder) ExchangeDelete ¶
func (mr *MockChannelMockRecorder) ExchangeDelete(arg0, arg1, arg2 interface{}) *gomock.Call
ExchangeDelete indicates an expected call of ExchangeDelete
func (*MockChannelMockRecorder) ExchangeUnbind ¶
func (mr *MockChannelMockRecorder) ExchangeUnbind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
ExchangeUnbind indicates an expected call of ExchangeUnbind
func (*MockChannelMockRecorder) Flow ¶
func (mr *MockChannelMockRecorder) Flow(arg0 interface{}) *gomock.Call
Flow indicates an expected call of Flow
func (*MockChannelMockRecorder) Get ¶
func (mr *MockChannelMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockChannelMockRecorder) Nack ¶
func (mr *MockChannelMockRecorder) Nack(arg0, arg1, arg2 interface{}) *gomock.Call
Nack indicates an expected call of Nack
func (*MockChannelMockRecorder) NotifyCancel ¶
func (mr *MockChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call
NotifyCancel indicates an expected call of NotifyCancel
func (*MockChannelMockRecorder) NotifyClose ¶
func (mr *MockChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
NotifyClose indicates an expected call of NotifyClose
func (*MockChannelMockRecorder) NotifyConfirm ¶
func (mr *MockChannelMockRecorder) NotifyConfirm(arg0, arg1 interface{}) *gomock.Call
NotifyConfirm indicates an expected call of NotifyConfirm
func (*MockChannelMockRecorder) NotifyFlow ¶
func (mr *MockChannelMockRecorder) NotifyFlow(arg0 interface{}) *gomock.Call
NotifyFlow indicates an expected call of NotifyFlow
func (*MockChannelMockRecorder) NotifyPublish ¶
func (mr *MockChannelMockRecorder) NotifyPublish(arg0 interface{}) *gomock.Call
NotifyPublish indicates an expected call of NotifyPublish
func (*MockChannelMockRecorder) NotifyReturn ¶
func (mr *MockChannelMockRecorder) NotifyReturn(arg0 interface{}) *gomock.Call
NotifyReturn indicates an expected call of NotifyReturn
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) QueueDeclarePassive ¶
func (mr *MockChannelMockRecorder) QueueDeclarePassive(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
QueueDeclarePassive indicates an expected call of QueueDeclarePassive
func (*MockChannelMockRecorder) QueueDelete ¶
func (mr *MockChannelMockRecorder) QueueDelete(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
QueueDelete indicates an expected call of QueueDelete
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
func (*MockChannelMockRecorder) QueueUnbind ¶
func (mr *MockChannelMockRecorder) QueueUnbind(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
QueueUnbind indicates an expected call of QueueUnbind
func (*MockChannelMockRecorder) Recover ¶
func (mr *MockChannelMockRecorder) Recover(arg0 interface{}) *gomock.Call
Recover indicates an expected call of Recover
func (*MockChannelMockRecorder) Reject ¶
func (mr *MockChannelMockRecorder) Reject(arg0, arg1 interface{}) *gomock.Call
Reject indicates an expected call of Reject
func (*MockChannelMockRecorder) Tx ¶
func (mr *MockChannelMockRecorder) Tx() *gomock.Call
Tx indicates an expected call of Tx
func (*MockChannelMockRecorder) TxCommit ¶
func (mr *MockChannelMockRecorder) TxCommit() *gomock.Call
TxCommit indicates an expected call of TxCommit
func (*MockChannelMockRecorder) TxRollback ¶
func (mr *MockChannelMockRecorder) TxRollback() *gomock.Call
TxRollback indicates an expected call of TxRollback
type MockDialer ¶
type MockDialer struct {
// contains filtered or unexported fields
}
MockDialer is a mock of Dialer interface
func NewMockDialer ¶
func NewMockDialer(ctrl *gomock.Controller) *MockDialer
NewMockDialer creates a new mock instance
func (*MockDialer) Dial ¶
func (m *MockDialer) Dial(arg0 string) (*amqpmanager.AMQPConnection, error)
Dial mocks base method
func (*MockDialer) EXPECT ¶
func (m *MockDialer) EXPECT() *MockDialerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockDialerMockRecorder ¶
type MockDialerMockRecorder struct {
// contains filtered or unexported fields
}
MockDialerMockRecorder is the mock recorder for MockDialer
func (*MockDialerMockRecorder) Dial ¶
func (mr *MockDialerMockRecorder) Dial(arg0 interface{}) *gomock.Call
Dial indicates an expected call of Dial