mocks

package
v1.3.2 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AMQPChannel 

type AMQPChannel struct {
	mock.Mock
}

AMQPChannel is an autogenerated mock type for the AMQPChannel type

func (*AMQPChannel) Close 

func (_m *AMQPChannel) Close() error

Close provides a mock function with given fields:

func (*AMQPChannel) Consume 

func (_m *AMQPChannel) Consume(queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

Consume provides a mock function with given fields: queue, consumer, autoAck, exclusive, noLocal, noWait, args

func (*AMQPChannel) ExchangeBind added in v1.3.2 

func (_m *AMQPChannel) ExchangeBind(destination string, key string, source string, noWait bool, args amqp.Table) error

ExchangeBind provides a mock function with given fields: destination, key, source, noWait, args

func (*AMQPChannel) ExchangeDeclare added in v1.3.2 

func (_m *AMQPChannel) ExchangeDeclare(name string, kind string, durable bool, autoDelete bool, internal bool, noWait bool, args amqp.Table) error

ExchangeDeclare provides a mock function with given fields: name, kind, durable, autoDelete, internal, noWait, args

func (*AMQPChannel) Publish 

func (_m *AMQPChannel) Publish(exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error

Publish provides a mock function with given fields: exchange, key, mandatory, immediate, msg

func (*AMQPChannel) QueueBind added in v1.3.2 

func (_m *AMQPChannel) QueueBind(name string, key string, exchange string, noWait bool, args amqp.Table) error

QueueBind provides a mock function with given fields: name, key, exchange, noWait, args

func (*AMQPChannel) QueueDeclare 

func (_m *AMQPChannel) QueueDeclare(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table) (amqp.Queue, error)

QueueDeclare provides a mock function with given fields: name, durable, autoDelete, exclusive, noWait, args

func (*AMQPChannel) Tx 

func (_m *AMQPChannel) Tx() error

Tx provides a mock function with given fields:

func (*AMQPChannel) TxCommit 

func (_m *AMQPChannel) TxCommit() error

TxCommit provides a mock function with given fields:

func (*AMQPChannel) TxRollback 

func (_m *AMQPChannel) TxRollback() error

TxRollback provides a mock function with given fields:

type AMQPConnection 

type AMQPConnection struct {
	mock.Mock
}

AMQPConnection is an autogenerated mock type for the AMQPConnection type

func (*AMQPConnection) Channel 

func (_m *AMQPConnection) Channel() (*amqp.Channel, error)

Channel provides a mock function with given fields:

func (*AMQPConnection) Close 

func (_m *AMQPConnection) Close() error

Close provides a mock function with given fields:

func (*AMQPConnection) NotifyBlocked added in v1.0.3 

func (_m *AMQPConnection) NotifyBlocked(receiver chan amqp.Blocking) chan amqp.Blocking

NotifyBlocked provides a mock function with given fields: receiver

func (*AMQPConnection) NotifyClose added in v1.0.3 

func (_m *AMQPConnection) NotifyClose(receiver chan *amqp.Error) chan *amqp.Error

NotifyClose provides a mock function with given fields: receiver

type AMQPDelivery 

type AMQPDelivery struct {
	mock.Mock
}

AMQPDelivery is an autogenerated mock type for the AMQPDelivery type

func (*AMQPDelivery) Reject 

func (_m *AMQPDelivery) Reject(requeue bool) error

Reject provides a mock function with given fields: requeue

type AMQPMessage 

type AMQPMessage struct {
	mock.Mock
}

AMQPMessage is an autogenerated mock type for the AMQPMessage type

func (*AMQPMessage) CreateMessage 

func (_m *AMQPMessage) CreateMessage(body interface{}) (amqp.Publishing, error)

CreateMessage provides a mock function with given fields: body

func (*AMQPMessage) GetKickbackMessage 

func (_m *AMQPMessage) GetKickbackMessage(msg amqp.Delivery) (amqp.Publishing, error)

GetKickbackMessage provides a mock function with given fields: msg

func (*AMQPMessage) GetNextMessage 

func (_m *AMQPMessage) GetNextMessage(msg amqp.Delivery, body interface{}) (amqp.Publishing, error)

GetNextMessage provides a mock function with given fields: msg, body

type AMQPRepository 

type AMQPRepository struct {
	mock.Mock
}

AMQPRepository is an autogenerated mock type for the AMQPRepository type

func (*AMQPRepository) AddListeners added in v1.0.3 

func (_m *AMQPRepository) AddListeners(closeChan chan *amqp.Error, blockChan chan amqp.Blocking)

AddListeners provides a mock function with given fields: closeChan, blockChan

func (*AMQPRepository) GetChannel 

func (_m *AMQPRepository) GetChannel() (externals.AMQPChannel, error)

GetChannel provides a mock function with given fields:

func (*AMQPRepository) RejectDelivery 

func (_m *AMQPRepository) RejectDelivery(msg externals.AMQPDelivery, requeue bool) error

RejectDelivery provides a mock function with given fields: msg, requeue

func (*AMQPRepository) SwapConn 

func (_m *AMQPRepository) SwapConn(conn externals.AMQPConnection)

SwapConn provides a mock function with given fields: conn

type AMQPService 

type AMQPService struct {
	mock.Mock
}

AMQPService is an autogenerated mock type for the AMQPService type

func (*AMQPService) Channel added in v1.3.2 

func (_m *AMQPService) Channel() (externals.AMQPChannel, error)

Channel provides a mock function with given fields:

func (*AMQPService) Config added in v1.3.2 

func (_m *AMQPService) Config() config.Config

Config provides a mock function with given fields:

func (*AMQPService) Consume 

func (_m *AMQPService) Consume() (<-chan amqp.Delivery, error)

Consume provides a mock function with given fields:

func (*AMQPService) CreateExchange added in v1.3.2 

func (_m *AMQPService) CreateExchange() error

CreateExchange provides a mock function with given fields:

func (*AMQPService) CreateQueue 

func (_m *AMQPService) CreateQueue() error

CreateQueue provides a mock function with given fields:

func (*AMQPService) Requeue 

func (_m *AMQPService) Requeue(oldMsg amqp.Delivery, newMsg amqp.Publishing) error

Requeue provides a mock function with given fields: oldMsg, newMsg

func (*AMQPService) Send 

func (_m *AMQPService) Send(pub amqp.Publishing) error

Send provides a mock function with given fields: pub

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.