Documentation
¶
Overview ¶
Package rabbitmq implements the triton-core/amqp module
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrorEnsureExchange is returned when exchanges are unable to be created ErrorEnsureExchange = errors.New("failed to ensure exchange") // ErrorEnsureConsumerQueues is returned when consumer queues are unable to be created ErrorEnsureConsumerQueues = errors.New("failed to ensure consumer queues") // ErrorReconnecting is emitted when the channel is reconnecting ErrorReconnecting = errors.New("processor is reconnecting") // ErrorDied is emitted when a processor dies, with no hope of recovering ErrorDied = errors.New("processor died") )
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a RabbitMQ client TODO(jaredallard): all of these maps :(
func (*Client) SetPrefetch ¶
SetPrefetch updates the prefetch of our channels
type Delivery ¶
type Delivery struct {
Metadata DeliveryMetadata
// Delivery is the internal amqp delivery struct
Delivery amqp.Delivery
// Channel this message was received on
Channel *amqp.Channel
// Context is the context this delivery is running under
Context context.Context
}
Delivery is an AMQP delivery
func NewDelivery ¶
func NewDelivery(ctx context.Context, delivery amqp.Delivery, channel *amqp.Channel) (*Delivery, error)
NewDelivery creates a delivery object
type DeliveryMetadata ¶
type DeliveryMetadata struct {
Retries int
}
DeliveryMetadata is metadata from AMQP headers
type MessageQueued ¶
type MessageQueued struct {
// AMQP topic to publish on
Topic string
// Message is the AMQP message object
Message amqp.Publishing
// Backoff is set when an error has occurred, and is modified
Backoff uint
}
Source Files
Click to show internal directories.
Click to hide internal directories.