externals

package
Version: v1.8.21 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2019 License: GPL-3.0 Imports: 3 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 interface {
	Close() error
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	Tx() error
	TxCommit() error
	TxRollback() error
}

AMQPChannel represents the needed functionality from a amqp.Channel

type AMQPConnection

type AMQPConnection interface {
	Channel() (*amqp.Channel, error)
	Close() error
}

AMQPConnection represents the needed functionality from a amqp.Connection

type AMQPDelivery

type AMQPDelivery interface {
	Reject(requeue bool) error
}

AMQPDelivery represents the needed functionality from a amqp.Delivery

type Context

type Context interface {
	context.Context
}

Context is context.Context pulled into this interface for mocking

type NetConn

type NetConn interface {
	net.Conn
}

NetConn is just net.Conn pulled into another interface for mocking

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL