mock_consumer

Documentation

Overview

Package mock_consumer is a generated GoMock package.

Index

• type MockAMQPChannel
  • func NewMockAMQPChannel(ctrl *gomock.Controller) *MockAMQPChannel
  • func (m *MockAMQPChannel) Cancel(arg0 string, arg1 bool) error
  • func (m *MockAMQPChannel) Close() error
  • func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.Delivery, error)
  • func (m *MockAMQPChannel) EXPECT() *MockAMQPChannelMockRecorder
  • func (m *MockAMQPChannel) NotifyCancel(arg0 chan string) chan string
  • func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp091.Error) chan *amqp091.Error
  • func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error
  • func (m *MockAMQPChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp091.Table) error
  • func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.Queue, error)
• type MockAMQPChannelMockRecorder
  • func (mr *MockAMQPChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
  • func (mr *MockAMQPChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
• type MockAMQPConnection
  • func NewMockAMQPConnection(ctrl *gomock.Controller) *MockAMQPConnection
  • func (m *MockAMQPConnection) EXPECT() *MockAMQPConnectionMockRecorder
• type MockAMQPConnectionMockRecorder

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) Cancel

func (m *MockAMQPChannel) Cancel(arg0 string, arg1 bool) error

Cancel mocks base method.

func (*MockAMQPChannel) Close

func (m *MockAMQPChannel) Close() error

Close mocks base method.

func (*MockAMQPChannel) Consume

func (m *MockAMQPChannel) Consume(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp091.Table) (<-chan amqp091.Delivery, error)

Consume 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) NotifyCancel

func (m *MockAMQPChannel) NotifyCancel(arg0 chan string) chan string

NotifyCancel mocks base method.

func (*MockAMQPChannel) NotifyClose

func (m *MockAMQPChannel) NotifyClose(arg0 chan *amqp091.Error) chan *amqp091.Error

NotifyClose mocks base method.

func (*MockAMQPChannel) Qos

func (m *MockAMQPChannel) Qos(arg0, arg1 int, arg2 bool) error

Qos mocks base method.

func (*MockAMQPChannel) QueueBind

func (m *MockAMQPChannel) QueueBind(arg0, arg1, arg2 string, arg3 bool, arg4 amqp091.Table) error

QueueBind mocks base method.

func (*MockAMQPChannel) QueueDeclare

func (m *MockAMQPChannel) QueueDeclare(arg0 string, arg1, arg2, arg3, arg4 bool, arg5 amqp091.Table) (amqp091.Queue, error)

QueueDeclare mocks base method.

type MockAMQPChannelMockRecorder

type MockAMQPChannelMockRecorder struct {
	// contains filtered or unexported fields
}

MockAMQPChannelMockRecorder is the mock recorder for MockAMQPChannel.

func (*MockAMQPChannelMockRecorder) Cancel

func (mr *MockAMQPChannelMockRecorder) Cancel(arg0, arg1 interface{}) *gomock.Call

Cancel indicates an expected call of Cancel.

func (*MockAMQPChannelMockRecorder) Close

func (mr *MockAMQPChannelMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockAMQPChannelMockRecorder) Consume

func (mr *MockAMQPChannelMockRecorder) Consume(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

Consume indicates an expected call of Consume.

func (*MockAMQPChannelMockRecorder) NotifyCancel

func (mr *MockAMQPChannelMockRecorder) NotifyCancel(arg0 interface{}) *gomock.Call

NotifyCancel indicates an expected call of NotifyCancel.

func (*MockAMQPChannelMockRecorder) NotifyClose

func (mr *MockAMQPChannelMockRecorder) NotifyClose(arg0 interface{}) *gomock.Call

NotifyClose indicates an expected call of NotifyClose.

func (*MockAMQPChannelMockRecorder) Qos

func (mr *MockAMQPChannelMockRecorder) Qos(arg0, arg1, arg2 interface{}) *gomock.Call

Qos indicates an expected call of Qos.

func (*MockAMQPChannelMockRecorder) QueueBind

func (mr *MockAMQPChannelMockRecorder) QueueBind(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

QueueBind indicates an expected call of QueueBind.

func (*MockAMQPChannelMockRecorder) QueueDeclare

func (mr *MockAMQPChannelMockRecorder) QueueDeclare(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

QueueDeclare indicates an expected call of QueueDeclare.

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.