mocks

Documentation

Index

• type RabbitInterface
  • func (_m *RabbitInterface) CreateFanoutExchange(channel *amqp.Channel, name string) error
  • func (_m *RabbitInterface) GetChannel(conn *amqp.Connection) *amqp.Channel
  • func (_m *RabbitInterface) GetConnection(uri string) *amqp.Connection
  • func (_m *RabbitInterface) GetConsumer(channel *amqp.Channel, queue string, consumer string, autoAck bool, ...) (<-chan amqp.Delivery, error)
  • func (_m *RabbitInterface) Publish(channel *amqp.Channel, exchange string, key string, mandatory bool, ...) error
  • func (_m *RabbitInterface) QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, ...) (amqp.Queue, error)

Types

type RabbitInterface

type RabbitInterface struct {
	mock.Mock
}

RabbitInterface is an autogenerated mock type for the RabbitInterface type

func (*RabbitInterface) CreateFanoutExchange

func (_m *RabbitInterface) CreateFanoutExchange(channel *amqp.Channel, name string) error

CreateFanoutExchange provides a mock function with given fields: channel, name

func (*RabbitInterface) GetChannel

func (_m *RabbitInterface) GetChannel(conn *amqp.Connection) *amqp.Channel

GetChannel provides a mock function with given fields: conn

func (*RabbitInterface) GetConnection

func (_m *RabbitInterface) GetConnection(uri string) *amqp.Connection

GetConnection provides a mock function with given fields: uri

func (*RabbitInterface) GetConsumer

func (_m *RabbitInterface) GetConsumer(channel *amqp.Channel, queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

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

func (*RabbitInterface) Publish

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

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

func (*RabbitInterface) QueueDeclare

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

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