Categorygithub.com/tritonmedia/downloader-gointernalrabbitmq
package
0.0.0-20200515011327-7d4b7a984faf
Repository: https://github.com/tritonmedia/downloader-go.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
11
Dependents
1
Files
459 SLOC

# Functions

NewClient returns a new rabbitmq client.
NewDelivery creates a delivery object.

# Variables

ErrorDied is emitted when a processor dies, with no hope of recovering.
ErrorEnsureConsumerQueues is returned when consumer queues are unable to be created.
ErrorEnsureExchange is returned when exchanges are unable to be created.
ErrorReconnecting is emitted when the channel is reconnecting.

# Structs

Client is a RabbitMQ client TODO(jaredallard): all of these maps :(.
Delivery is an AMQP delivery.
DeliveryMetadata is metadata from AMQP headers.
No description provided by the author