externals

Documentation

Index

• type AMQPChannel
• type AMQPConnection
• type AMQPDelivery
• type Context
• type NetConn

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