Documentation
¶
Index ¶
- Variables
- func New(url string) (queue.Broker, error)
- type Acknowledger
- type Broker
- type Configuration
- type JobIter
- type Queue
- func (q *Queue) Consume(advertisedWindow int) (queue.JobIter, error)
- func (q *Queue) Publish(j *queue.Job) (err error)
- func (q *Queue) PublishDelayed(j *queue.Job, delay time.Duration) error
- func (q *Queue) RepublishBuried(conditions ...queue.RepublishConditionFunc) error
- func (q *Queue) Transaction(txcb queue.TxCallback) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrConnectionFailed = errors.NewKind("failed to connect to RabbitMQ: %s") ErrOpenChannel = errors.NewKind("failed to open a channel: %s") ErrRetrievingHeader = errors.NewKind("error retrieving '%s' header from message %s") ErrRepublishingJobs = errors.NewKind("couldn't republish some jobs : %s") )
Functions ¶
Types ¶
type Acknowledger ¶
type Acknowledger struct {
// contains filtered or unexported fields
}
Acknowledger implements the Acknowledger for AMQP.
func (*Acknowledger) Reject ¶
func (a *Acknowledger) Reject(requeue bool) error
Reject signals rejection. If requeue is false, the job will go to the buried queue until Queue.RepublishBuried() is called.
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
Broker implements the queue.Broker interface for AMQP, such as RabbitMQ.
type Configuration ¶
type Configuration struct {
BuriedQueueSuffix string `envconfig:"BURIED_QUEUE_SUFFIX" default:".buriedQueue"`
BuriedExchangeSuffix string `envconfig:"BURIED_EXCHANGE_SUFFIX" default:".buriedExchange"`
BuriedTimeout int `envconfig:"BURIED_TIMEOUT" default:"500"`
RetriesHeader string `envconfig:"RETRIES_HEADER" default:"x-retries"`
ErrorHeader string `envconfig:"ERROR_HEADER" default:"x-error-type"`
BackoffMin time.Duration `envconfig:"BACKOFF_MIN" default:"200ms"`
BackoffMax time.Duration `envconfig:"BACKOFF_MAX" default:"30s"`
BackoffFactor float64 `envconfig:"BACKOFF_FACTOR" default:"2"`
}
Configuration AMQP configuration settings, this settings are set using the environment variables.
var DefaultConfiguration Configuration
DefaultConfiguration contains the default configuration initialized from environment variables.
type JobIter ¶
type JobIter struct {
// contains filtered or unexported fields
}
JobIter implements the JobIter interface for AMQP.
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue implements the Queue interface for the AMQP.
func (*Queue) Consume ¶
Consume implements the Queue interface. The advertisedWindow value is the maximum number of unacknowledged jobs
func (*Queue) PublishDelayed ¶
PublishDelayed publishes the given Job with a given delay. Delayed messages will not go into the buried queue if they fail.
func (*Queue) RepublishBuried ¶
RepublishBuried will republish in the main queue those jobs that timed out without Ack or were Rejected with requeue = False and makes comply return true.
func (*Queue) Transaction ¶
Transaction executes the given callback inside a transaction.
Source Files