mock_source

package
v1.15.2 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2022 License: LGPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock_source is a generated GoMock package.

Index

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

func (m *MockAMQPChannel) Ack(tag uint64, multiple bool) error

Ack mocks base method.

func (*MockAMQPChannel) Cancel 

func (m *MockAMQPChannel) Cancel(consumer string, noWait bool) error

Cancel mocks base method.

func (*MockAMQPChannel) Close 

func (m *MockAMQPChannel) Close() error

Close mocks base method.

func (*MockAMQPChannel) Confirm 

func (m *MockAMQPChannel) Confirm(noWait bool) error

Confirm mocks base method.

func (*MockAMQPChannel) Consume 

func (m *MockAMQPChannel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args 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) ExchangeBind 

func (m *MockAMQPChannel) ExchangeBind(destination, key, source string, noWait bool, args amqp091.Table) error

ExchangeBind mocks base method.

func (*MockAMQPChannel) ExchangeDeclare 

func (m *MockAMQPChannel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp091.Table) error

ExchangeDeclare mocks base method.

func (*MockAMQPChannel) ExchangeDeclarePassive 

func (m *MockAMQPChannel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp091.Table) error

ExchangeDeclarePassive mocks base method.

func (*MockAMQPChannel) ExchangeDelete 

func (m *MockAMQPChannel) ExchangeDelete(name string, ifUnused, noWait bool) error

ExchangeDelete mocks base method.

func (*MockAMQPChannel) ExchangeUnbind 

func (m *MockAMQPChannel) ExchangeUnbind(destination, key, source string, noWait bool, args amqp091.Table) error

ExchangeUnbind mocks base method.

func (*MockAMQPChannel) Flow 

func (m *MockAMQPChannel) Flow(active bool) error

Flow mocks base method.

func (*MockAMQPChannel) Get 

func (m *MockAMQPChannel) Get(queue string, autoAck bool) (amqp091.Delivery, bool, error)

Get mocks base method.

func (*MockAMQPChannel) GetNextPublishSeqNo 

func (m *MockAMQPChannel) GetNextPublishSeqNo() uint64

GetNextPublishSeqNo mocks base method.

func (*MockAMQPChannel) IsClosed 

func (m *MockAMQPChannel) IsClosed() bool

IsClosed mocks base method.

func (*MockAMQPChannel) Nack 

func (m *MockAMQPChannel) Nack(tag uint64, multiple, requeue bool) error

Nack mocks base method.

func (*MockAMQPChannel) NotifyCancel 

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

NotifyCancel mocks base method.

func (*MockAMQPChannel) NotifyClose 

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

NotifyClose mocks base method.

func (*MockAMQPChannel) NotifyConfirm 

func (m *MockAMQPChannel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)

NotifyConfirm mocks base method.

func (*MockAMQPChannel) NotifyFlow 

func (m *MockAMQPChannel) NotifyFlow(c chan bool) chan bool

NotifyFlow mocks base method.

func (*MockAMQPChannel) NotifyPublish 

func (m *MockAMQPChannel) NotifyPublish(confirm chan amqp091.Confirmation) chan amqp091.Confirmation

NotifyPublish mocks base method.

func (*MockAMQPChannel) NotifyReturn 

func (m *MockAMQPChannel) NotifyReturn(c chan amqp091.Return) chan amqp091.Return

NotifyReturn mocks base method.

func (*MockAMQPChannel) Publish 

func (m *MockAMQPChannel) Publish(exchange, key string, mandatory, immediate bool, msg amqp091.Publishing) error

Publish mocks base method.

func (*MockAMQPChannel) PublishWithDeferredConfirm 

func (m *MockAMQPChannel) PublishWithDeferredConfirm(exchange, key string, mandatory, immediate bool, msg amqp091.Publishing) (*amqp091.DeferredConfirmation, error)

PublishWithDeferredConfirm mocks base method.

func (*MockAMQPChannel) Qos 

func (m *MockAMQPChannel) Qos(prefetchCount, prefetchSize int, global bool) error

Qos mocks base method.

func (*MockAMQPChannel) QueueBind 

func (m *MockAMQPChannel) QueueBind(name, key, exchange string, noWait bool, args amqp091.Table) error

QueueBind mocks base method.

func (*MockAMQPChannel) QueueDeclare 

func (m *MockAMQPChannel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp091.Table) (amqp091.Queue, error)

QueueDeclare mocks base method.

func (*MockAMQPChannel) QueueDeclarePassive 

func (m *MockAMQPChannel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args amqp091.Table) (amqp091.Queue, error)

QueueDeclarePassive mocks base method.

func (*MockAMQPChannel) QueueDelete 

func (m *MockAMQPChannel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)

QueueDelete mocks base method.

func (*MockAMQPChannel) QueueInspect 

func (m *MockAMQPChannel) QueueInspect(name string) (amqp091.Queue, error)

QueueInspect mocks base method.

func (*MockAMQPChannel) QueuePurge 

func (m *MockAMQPChannel) QueuePurge(name string, noWait bool) (int, error)

QueuePurge mocks base method.

func (*MockAMQPChannel) QueueUnbind 

func (m *MockAMQPChannel) QueueUnbind(name, key, exchange string, args amqp091.Table) error

QueueUnbind mocks base method.

func (*MockAMQPChannel) Recover 

func (m *MockAMQPChannel) Recover(requeue bool) error

Recover mocks base method.

func (*MockAMQPChannel) Reject 

func (m *MockAMQPChannel) Reject(tag uint64, requeue bool) error

Reject mocks base method.

func (*MockAMQPChannel) Tx 

func (m *MockAMQPChannel) Tx() error

Tx mocks base method.

func (*MockAMQPChannel) TxCommit 

func (m *MockAMQPChannel) TxCommit() error

TxCommit mocks base method.

func (*MockAMQPChannel) TxRollback 

func (m *MockAMQPChannel) TxRollback() error

TxRollback mocks base method.

type MockAMQPChannelMockRecorder 

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

MockAMQPChannelMockRecorder is the mock recorder for MockAMQPChannel.

func (*MockAMQPChannelMockRecorder) Ack 

func (mr *MockAMQPChannelMockRecorder) Ack(tag, multiple interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*MockAMQPChannelMockRecorder) Cancel 

func (mr *MockAMQPChannelMockRecorder) Cancel(consumer, noWait 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) Confirm 

func (mr *MockAMQPChannelMockRecorder) Confirm(noWait interface{}) *gomock.Call

Confirm indicates an expected call of Confirm.

func (*MockAMQPChannelMockRecorder) Consume 

func (mr *MockAMQPChannelMockRecorder) Consume(queue, consumer, autoAck, exclusive, noLocal, noWait, args interface{}) *gomock.Call

Consume indicates an expected call of Consume.

func (*MockAMQPChannelMockRecorder) ExchangeBind 

func (mr *MockAMQPChannelMockRecorder) ExchangeBind(destination, key, source, noWait, args interface{}) *gomock.Call

ExchangeBind indicates an expected call of ExchangeBind.

func (*MockAMQPChannelMockRecorder) ExchangeDeclare 

func (mr *MockAMQPChannelMockRecorder) ExchangeDeclare(name, kind, durable, autoDelete, internal, noWait, args interface{}) *gomock.Call

ExchangeDeclare indicates an expected call of ExchangeDeclare.

func (*MockAMQPChannelMockRecorder) ExchangeDeclarePassive 

func (mr *MockAMQPChannelMockRecorder) ExchangeDeclarePassive(name, kind, durable, autoDelete, internal, noWait, args interface{}) *gomock.Call

ExchangeDeclarePassive indicates an expected call of ExchangeDeclarePassive.

func (*MockAMQPChannelMockRecorder) ExchangeDelete 

func (mr *MockAMQPChannelMockRecorder) ExchangeDelete(name, ifUnused, noWait interface{}) *gomock.Call

ExchangeDelete indicates an expected call of ExchangeDelete.

func (*MockAMQPChannelMockRecorder) ExchangeUnbind 

func (mr *MockAMQPChannelMockRecorder) ExchangeUnbind(destination, key, source, noWait, args interface{}) *gomock.Call

ExchangeUnbind indicates an expected call of ExchangeUnbind.

func (*MockAMQPChannelMockRecorder) Flow 

func (mr *MockAMQPChannelMockRecorder) Flow(active interface{}) *gomock.Call

Flow indicates an expected call of Flow.

func (*MockAMQPChannelMockRecorder) Get 

func (mr *MockAMQPChannelMockRecorder) Get(queue, autoAck interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockAMQPChannelMockRecorder) GetNextPublishSeqNo 

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

GetNextPublishSeqNo indicates an expected call of GetNextPublishSeqNo.

func (*MockAMQPChannelMockRecorder) IsClosed 

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

IsClosed indicates an expected call of IsClosed.

func (*MockAMQPChannelMockRecorder) Nack 

func (mr *MockAMQPChannelMockRecorder) Nack(tag, multiple, requeue interface{}) *gomock.Call

Nack indicates an expected call of Nack.

func (*MockAMQPChannelMockRecorder) NotifyCancel 

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

NotifyCancel indicates an expected call of NotifyCancel.

func (*MockAMQPChannelMockRecorder) NotifyClose 

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

NotifyClose indicates an expected call of NotifyClose.

func (*MockAMQPChannelMockRecorder) NotifyConfirm 

func (mr *MockAMQPChannelMockRecorder) NotifyConfirm(ack, nack interface{}) *gomock.Call

NotifyConfirm indicates an expected call of NotifyConfirm.

func (*MockAMQPChannelMockRecorder) NotifyFlow 

func (mr *MockAMQPChannelMockRecorder) NotifyFlow(c interface{}) *gomock.Call

NotifyFlow indicates an expected call of NotifyFlow.

func (*MockAMQPChannelMockRecorder) NotifyPublish 

func (mr *MockAMQPChannelMockRecorder) NotifyPublish(confirm interface{}) *gomock.Call

NotifyPublish indicates an expected call of NotifyPublish.

func (*MockAMQPChannelMockRecorder) NotifyReturn 

func (mr *MockAMQPChannelMockRecorder) NotifyReturn(c interface{}) *gomock.Call

NotifyReturn indicates an expected call of NotifyReturn.

func (*MockAMQPChannelMockRecorder) Publish 

func (mr *MockAMQPChannelMockRecorder) Publish(exchange, key, mandatory, immediate, msg interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockAMQPChannelMockRecorder) PublishWithDeferredConfirm 

func (mr *MockAMQPChannelMockRecorder) PublishWithDeferredConfirm(exchange, key, mandatory, immediate, msg interface{}) *gomock.Call

PublishWithDeferredConfirm indicates an expected call of PublishWithDeferredConfirm.

func (*MockAMQPChannelMockRecorder) Qos 

func (mr *MockAMQPChannelMockRecorder) Qos(prefetchCount, prefetchSize, global interface{}) *gomock.Call

Qos indicates an expected call of Qos.

func (*MockAMQPChannelMockRecorder) QueueBind 

func (mr *MockAMQPChannelMockRecorder) QueueBind(name, key, exchange, noWait, args interface{}) *gomock.Call

QueueBind indicates an expected call of QueueBind.

func (*MockAMQPChannelMockRecorder) QueueDeclare 

func (mr *MockAMQPChannelMockRecorder) QueueDeclare(name, durable, autoDelete, exclusive, noWait, args interface{}) *gomock.Call

QueueDeclare indicates an expected call of QueueDeclare.

func (*MockAMQPChannelMockRecorder) QueueDeclarePassive 

func (mr *MockAMQPChannelMockRecorder) QueueDeclarePassive(name, durable, autoDelete, exclusive, noWait, args interface{}) *gomock.Call

QueueDeclarePassive indicates an expected call of QueueDeclarePassive.

func (*MockAMQPChannelMockRecorder) QueueDelete 

func (mr *MockAMQPChannelMockRecorder) QueueDelete(name, ifUnused, ifEmpty, noWait interface{}) *gomock.Call

QueueDelete indicates an expected call of QueueDelete.

func (*MockAMQPChannelMockRecorder) QueueInspect 

func (mr *MockAMQPChannelMockRecorder) QueueInspect(name interface{}) *gomock.Call

QueueInspect indicates an expected call of QueueInspect.

func (*MockAMQPChannelMockRecorder) QueuePurge 

func (mr *MockAMQPChannelMockRecorder) QueuePurge(name, noWait interface{}) *gomock.Call

QueuePurge indicates an expected call of QueuePurge.

func (*MockAMQPChannelMockRecorder) QueueUnbind 

func (mr *MockAMQPChannelMockRecorder) QueueUnbind(name, key, exchange, args interface{}) *gomock.Call

QueueUnbind indicates an expected call of QueueUnbind.

func (*MockAMQPChannelMockRecorder) Recover 

func (mr *MockAMQPChannelMockRecorder) Recover(requeue interface{}) *gomock.Call

Recover indicates an expected call of Recover.

func (*MockAMQPChannelMockRecorder) Reject 

func (mr *MockAMQPChannelMockRecorder) Reject(tag, requeue interface{}) *gomock.Call

Reject indicates an expected call of Reject.

func (*MockAMQPChannelMockRecorder) Tx 

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

Tx indicates an expected call of Tx.

func (*MockAMQPChannelMockRecorder) TxCommit 

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

TxCommit indicates an expected call of TxCommit.

func (*MockAMQPChannelMockRecorder) TxRollback 

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

TxRollback indicates an expected call of TxRollback.

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

func (m *MockAMQPConnection) Channel() (client.AMQPChannel, error)

Channel mocks base method.

func (*MockAMQPConnection) Close 

func (m *MockAMQPConnection) Close() error

Close mocks base method.

func (*MockAMQPConnection) ConnectionState 

func (m *MockAMQPConnection) ConnectionState() tls.ConnectionState

ConnectionState mocks base method.

func (*MockAMQPConnection) EXPECT 

func (m *MockAMQPConnection) EXPECT() *MockAMQPConnectionMockRecorder

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

func (*MockAMQPConnection) IsClosed 

func (m *MockAMQPConnection) IsClosed() bool

IsClosed mocks base method.

func (*MockAMQPConnection) LocalAddr 

func (m *MockAMQPConnection) LocalAddr() net.Addr

LocalAddr mocks base method.

func (*MockAMQPConnection) NotifyBlocked 

func (m *MockAMQPConnection) NotifyBlocked(receiver chan amqp091.Blocking) chan amqp091.Blocking

NotifyBlocked mocks base method.

func (*MockAMQPConnection) NotifyClose 

func (m *MockAMQPConnection) NotifyClose(receiver chan *amqp091.Error) chan *amqp091.Error

NotifyClose mocks base method.

type MockAMQPConnectionMockRecorder 

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

MockAMQPConnectionMockRecorder is the mock recorder for MockAMQPConnection.

func (*MockAMQPConnectionMockRecorder) Channel 

func (mr *MockAMQPConnectionMockRecorder) Channel() *gomock.Call

Channel indicates an expected call of Channel.

func (*MockAMQPConnectionMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockAMQPConnectionMockRecorder) ConnectionState 

func (mr *MockAMQPConnectionMockRecorder) ConnectionState() *gomock.Call

ConnectionState indicates an expected call of ConnectionState.

func (*MockAMQPConnectionMockRecorder) IsClosed 

func (mr *MockAMQPConnectionMockRecorder) IsClosed() *gomock.Call

IsClosed indicates an expected call of IsClosed.

func (*MockAMQPConnectionMockRecorder) LocalAddr 

func (mr *MockAMQPConnectionMockRecorder) LocalAddr() *gomock.Call

LocalAddr indicates an expected call of LocalAddr.

func (*MockAMQPConnectionMockRecorder) NotifyBlocked 

func (mr *MockAMQPConnectionMockRecorder) NotifyBlocked(receiver interface{}) *gomock.Call

NotifyBlocked indicates an expected call of NotifyBlocked.

func (*MockAMQPConnectionMockRecorder) NotifyClose 

func (mr *MockAMQPConnectionMockRecorder) NotifyClose(receiver interface{}) *gomock.Call

NotifyClose indicates an expected call of NotifyClose.

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.