channel

package
v0.0.0-...-dabc275 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package mock_channel is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Channel 

type Channel struct {
	QueueName string
	// contains filtered or unexported fields
}

func (*Channel) BindQueue 

func (ch *Channel) BindQueue() error

func (*Channel) BindQueueByConfig 

func (ch *Channel) BindQueueByConfig(bqc config.BindQueueConfig) error

func (*Channel) Close 

func (ch *Channel) Close() error

func (*Channel) Consume 

func (ch *Channel) Consume() (<-chan amqp.Delivery, error)

func (*Channel) ConsumeByConfig 

func (ch *Channel) ConsumeByConfig(cc config.ConsumerConfig) (<-chan amqp.Delivery, error)

func (*Channel) Create 

func (ch *Channel) Create(conn connection.RConnectionInterface) error

func (*Channel) ExchangeDeclare 

func (ch *Channel) ExchangeDeclare() error

func (*Channel) ExchangeDeclareByConfig 

func (ch *Channel) ExchangeDeclareByConfig(ec config.ExchangeConfig) error

func (*Channel) GetChannel 

func (ch *Channel) GetChannel() RChannelInterface

func (*Channel) Publish 

func (ch *Channel) Publish(body amqp.Publishing) error

func (*Channel) PublishWithParams 

func (ch *Channel) PublishWithParams(exchange, routingKey string, mandatory, immediate bool, body amqp.Publishing) error

func (*Channel) QueueDeclare 

func (ch *Channel) QueueDeclare(name string) error

func (*Channel) QueueDeclareByConfig 

func (ch *Channel) QueueDeclareByConfig(qc config.QueueConfig) error

type ChannelInterface 

type ChannelInterface interface {
	GetChannel() RChannelInterface
	Create(connection.RConnectionInterface) error
	Close() error
	QueueDeclare(string) error
	QueueDeclareByConfig(config.QueueConfig) error
	ExchangeDeclare() error
	ExchangeDeclareByConfig(config.ExchangeConfig) error
	BindQueue() error
	BindQueueByConfig(bqc config.BindQueueConfig) error
	Publish(amqp.Publishing) error
	PublishWithParams(exchange, routingKey string, mandatory, immediate bool, body amqp.Publishing) error
	Consume() (<-chan amqp.Delivery, error)
	ConsumeByConfig(cc config.ConsumerConfig) (<-chan amqp.Delivery, error)
}

type MockChannelInterface 

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

MockChannelInterface is a mock of ChannelInterface interface

func NewMockChannelInterface 

func NewMockChannelInterface(ctrl *gomock.Controller) *MockChannelInterface

NewMockChannelInterface creates a new mock instance

func (*MockChannelInterface) BindQueue 

func (m *MockChannelInterface) BindQueue() error

BindQueue mocks base method

func (*MockChannelInterface) BindQueueByConfig 

func (m *MockChannelInterface) BindQueueByConfig(bqc config.BindQueueConfig) error

BindQueueByConfig mocks base method

func (*MockChannelInterface) Close 

func (m *MockChannelInterface) Close() error

Close mocks base method

func (*MockChannelInterface) Consume 

func (m *MockChannelInterface) Consume() (<-chan amqp.Delivery, error)

Consume mocks base method

func (*MockChannelInterface) ConsumeByConfig 

func (m *MockChannelInterface) ConsumeByConfig(cc config.ConsumerConfig) (<-chan amqp.Delivery, error)

ConsumeByConfig mocks base method

func (*MockChannelInterface) Create 

func (m *MockChannelInterface) Create(arg0 connection.RConnectionInterface) error

Create mocks base method

func (*MockChannelInterface) EXPECT 

func (m *MockChannelInterface) EXPECT() *MockChannelInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockChannelInterface) ExchangeDeclare 

func (m *MockChannelInterface) ExchangeDeclare() error

ExchangeDeclare mocks base method

func (*MockChannelInterface) ExchangeDeclareByConfig 

func (m *MockChannelInterface) ExchangeDeclareByConfig(arg0 config.ExchangeConfig) error

ExchangeDeclareByConfig mocks base method

func (*MockChannelInterface) GetChannel 

func (m *MockChannelInterface) GetChannel() RChannelInterface

GetChannel mocks base method

func (*MockChannelInterface) Publish 

func (m *MockChannelInterface) Publish(arg0 amqp.Publishing) error

Publish mocks base method

func (*MockChannelInterface) PublishWithParams 

func (m *MockChannelInterface) PublishWithParams(exchange, routingKey string, mandatory, immediate bool, body amqp.Publishing) error

PublishWithParams mocks base method

func (*MockChannelInterface) QueueDeclare 

func (m *MockChannelInterface) QueueDeclare(arg0 string) error

QueueDeclare mocks base method

func (*MockChannelInterface) QueueDeclareByConfig 

func (m *MockChannelInterface) QueueDeclareByConfig(arg0 config.QueueConfig) error

QueueDeclareByConfig mocks base method

type MockChannelInterfaceMockRecorder 

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

MockChannelInterfaceMockRecorder is the mock recorder for MockChannelInterface

func (*MockChannelInterfaceMockRecorder) BindQueue 

func (mr *MockChannelInterfaceMockRecorder) BindQueue() *gomock.Call

BindQueue indicates an expected call of BindQueue

func (*MockChannelInterfaceMockRecorder) BindQueueByConfig 

func (mr *MockChannelInterfaceMockRecorder) BindQueueByConfig(bqc interface{}) *gomock.Call

BindQueueByConfig indicates an expected call of BindQueueByConfig

func (*MockChannelInterfaceMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockChannelInterfaceMockRecorder) Consume 

func (mr *MockChannelInterfaceMockRecorder) Consume() *gomock.Call

Consume indicates an expected call of Consume

func (*MockChannelInterfaceMockRecorder) ConsumeByConfig 

func (mr *MockChannelInterfaceMockRecorder) ConsumeByConfig(cc interface{}) *gomock.Call

ConsumeByConfig indicates an expected call of ConsumeByConfig

func (*MockChannelInterfaceMockRecorder) Create 

func (mr *MockChannelInterfaceMockRecorder) Create(arg0 interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockChannelInterfaceMockRecorder) ExchangeDeclare 

func (mr *MockChannelInterfaceMockRecorder) ExchangeDeclare() *gomock.Call

ExchangeDeclare indicates an expected call of ExchangeDeclare

func (*MockChannelInterfaceMockRecorder) ExchangeDeclareByConfig 

func (mr *MockChannelInterfaceMockRecorder) ExchangeDeclareByConfig(arg0 interface{}) *gomock.Call

ExchangeDeclareByConfig indicates an expected call of ExchangeDeclareByConfig

func (*MockChannelInterfaceMockRecorder) GetChannel 

func (mr *MockChannelInterfaceMockRecorder) GetChannel() *gomock.Call

GetChannel indicates an expected call of GetChannel

func (*MockChannelInterfaceMockRecorder) Publish 

func (mr *MockChannelInterfaceMockRecorder) Publish(arg0 interface{}) *gomock.Call

Publish indicates an expected call of Publish

func (*MockChannelInterfaceMockRecorder) PublishWithParams 

func (mr *MockChannelInterfaceMockRecorder) PublishWithParams(exchange, routingKey, mandatory, immediate, body interface{}) *gomock.Call

PublishWithParams indicates an expected call of PublishWithParams

func (*MockChannelInterfaceMockRecorder) QueueDeclare 

func (mr *MockChannelInterfaceMockRecorder) QueueDeclare(arg0 interface{}) *gomock.Call

QueueDeclare indicates an expected call of QueueDeclare

func (*MockChannelInterfaceMockRecorder) QueueDeclareByConfig 

func (mr *MockChannelInterfaceMockRecorder) QueueDeclareByConfig(arg0 interface{}) *gomock.Call

QueueDeclareByConfig indicates an expected call of QueueDeclareByConfig

type MockRChannelInterface 

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

MockRChannelInterface is a mock of RChannelInterface interface

func NewMockRChannelInterface 

func NewMockRChannelInterface(ctrl *gomock.Controller) *MockRChannelInterface

NewMockRChannelInterface creates a new mock instance

func (*MockRChannelInterface) Close 

func (m *MockRChannelInterface) Close() error

Close mocks base method

func (*MockRChannelInterface) Consume 

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

Consume mocks base method

func (*MockRChannelInterface) EXPECT 

func (m *MockRChannelInterface) EXPECT() *MockRChannelInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRChannelInterface) ExchangeDeclare 

func (m *MockRChannelInterface) ExchangeDeclare(arg0, arg1 string, arg2, arg3, arg4, arg5 bool, arg6 amqp.Table) error

ExchangeDeclare mocks base method

func (*MockRChannelInterface) Publish 

func (m *MockRChannelInterface) Publish(arg0, arg1 string, arg2, arg3 bool, arg4 amqp.Publishing) error

Publish mocks base method

func (*MockRChannelInterface) Qos 

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

Qos mocks base method

func (*MockRChannelInterface) QueueBind 

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

QueueBind mocks base method

func (*MockRChannelInterface) QueueDeclare 

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

QueueDeclare mocks base method

type MockRChannelInterfaceMockRecorder 

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

MockRChannelInterfaceMockRecorder is the mock recorder for MockRChannelInterface

func (*MockRChannelInterfaceMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockRChannelInterfaceMockRecorder) Consume 

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

Consume indicates an expected call of Consume

func (*MockRChannelInterfaceMockRecorder) ExchangeDeclare 

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

ExchangeDeclare indicates an expected call of ExchangeDeclare

func (*MockRChannelInterfaceMockRecorder) Publish 

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

Publish indicates an expected call of Publish

func (*MockRChannelInterfaceMockRecorder) Qos 

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

Qos indicates an expected call of Qos

func (*MockRChannelInterfaceMockRecorder) QueueBind 

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

QueueBind indicates an expected call of QueueBind

func (*MockRChannelInterfaceMockRecorder) QueueDeclare 

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

QueueDeclare indicates an expected call of QueueDeclare

type RChannelInterface 

type RChannelInterface interface {
	QueueDeclare(string, bool, bool, bool, bool, amqp.Table) (amqp.Queue, error)
	ExchangeDeclare(string, string, bool, bool, bool, bool, amqp.Table) error
	QueueBind(string, string, string, bool, amqp.Table) error
	Publish(string, string, bool, bool, amqp.Publishing) error
	Qos(int, int, bool) error
	Consume(string, string, bool, bool, bool, bool, amqp.Table) (<-chan amqp.Delivery, error)
	Close() error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.