Documentation ¶
Overview ¶
Package mock_publisher is a generated GoMock package.
Index ¶
- type MockAMQPChannel
- func (m *MockAMQPChannel) Close() error
- func (m *MockAMQPChannel) Confirm(arg0 bool) error
- func (m *MockAMQPChannel) EXPECT() *MockAMQPChannelMockRecorder
- func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp091.Error) chan *amqp091.Error
- func (m *MockAMQPChannel) NotifyFlow(arg0 chan bool) chan bool
- func (m *MockAMQPChannel) NotifyPublish(arg0 chan amqp091.Confirmation) chan amqp091.Confirmation
- func (m *MockAMQPChannel) PublishWithContext(arg0 context.Context, arg1, arg2 string, arg3, arg4 bool, ...) error
- type MockAMQPChannelMockRecorder
- func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) Confirm(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) NotifyFlow(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) NotifyPublish(arg0 interface{}) *gomock.Call
- func (mr *MockAMQPChannelMockRecorder) PublishWithContext(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) Confirm ¶ added in v0.16.0
func (m *MockAMQPChannel) Confirm(arg0 bool) error
Confirm 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) NotifyClose ¶
func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp091.Error) chan *amqp091.Error
NotifyClose mocks base method.
func (*MockAMQPChannel) NotifyFlow ¶
func (m *MockAMQPChannel) NotifyFlow(arg0 chan bool) chan bool
NotifyFlow mocks base method.
func (*MockAMQPChannel) NotifyPublish ¶ added in v0.16.0
func (m *MockAMQPChannel) NotifyPublish(arg0 chan amqp091.Confirmation) chan amqp091.Confirmation
NotifyPublish mocks base method.
func (*MockAMQPChannel) PublishWithContext ¶ added in v1.1.0
func (m *MockAMQPChannel) PublishWithContext(arg0 context.Context, arg1, arg2 string, arg3, arg4 bool, arg5 amqp091.Publishing) error
PublishWithContext mocks base method.
type MockAMQPChannelMockRecorder ¶
type MockAMQPChannelMockRecorder struct {
// contains filtered or unexported fields
}
MockAMQPChannelMockRecorder is the mock recorder for MockAMQPChannel.
func (*MockAMQPChannelMockRecorder) Close ¶
func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockAMQPChannelMockRecorder) Confirm ¶ added in v0.16.0
func (mr *MockAMQPChannelMockRecorder) Confirm(arg0 interface{}) *gomock.Call
Confirm indicates an expected call of Confirm.
func (*MockAMQPChannelMockRecorder) NotifyClose ¶
func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
NotifyClose indicates an expected call of NotifyClose.
func (*MockAMQPChannelMockRecorder) NotifyFlow ¶
func (mr *MockAMQPChannelMockRecorder) NotifyFlow(arg0 interface{}) *gomock.Call
NotifyFlow indicates an expected call of NotifyFlow.
func (*MockAMQPChannelMockRecorder) NotifyPublish ¶ added in v0.16.0
func (mr *MockAMQPChannelMockRecorder) NotifyPublish(arg0 interface{}) *gomock.Call
NotifyPublish indicates an expected call of NotifyPublish.
func (*MockAMQPChannelMockRecorder) PublishWithContext ¶ added in v1.1.0
func (mr *MockAMQPChannelMockRecorder) PublishWithContext(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
PublishWithContext indicates an expected call of PublishWithContext.
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.