queue

type AMQPAcknowledger struct {
	// contains filtered or unexported fields
}

type AMQPBroker struct {
	// contains filtered or unexported fields
}

type AMQPJobIter struct {
	// contains filtered or unexported fields
}

type AMQPQueue struct {
	// contains filtered or unexported fields
}

type Acknowledger interface {
	// Ack is called when the Job has finished.
	Ack() error
	// Reject is called if the job has errored. The parameter indicates
	// whether the job should be put back in the queue or not.
	Reject(requeue bool) error
}

type Broker interface {
	// Queue returns a Queue from the with the given name.
	Queue(string) (Queue, error)
	// Close closes the connection of the Broker.
	Close() error
}

type Job struct {
	// ID of the job.
	ID string
	// Priority is the priority level.
	Priority Priority
	// Timestamp is the time of creation.
	Timestamp time.Time
	// Retries is the number of times this job can be processed before being rejected.
	Retries int32
	// ErrorType is the kind of error that made the job failing.
	ErrorType string
	// contains filtered or unexported fields
}

type JobIter interface {
	// Next returns the next Job in the iterator. It should block until
	// the job becomes available or while too many undelivered jobs has
	// been already returned (see the argument to Queue.Consume). Returns
	// ErrAlreadyClosed if the iterator is closed.
	Next() (*Job, error)
	io.Closer
}

type Priority uint8

type Queue interface {
	// Publish publishes the given Job to the queue.
	Publish(*Job) error
	// Publish publishes the given Job to the queue with a given delay.
	PublishDelayed(*Job, time.Duration) error
	// Transaction executes the passed TxCallback inside a transaction.
	Transaction(TxCallback) error
	// Consume returns a JobIter for the queue.  Ir receives the minimum
	// number of undelivered jobs the iterator will allow at any given
	// time (see the Acknowledger interface).
	Consume(advertisedWindow int) (JobIter, error)
	// RepublishBuried republish to the main queue those jobs complying
	// one of the conditions, leaving the rest of them in the buried queue.
	RepublishBuried(conditions ...RepublishConditionFunc) error
}

type RepublishConditionFunc func(job *Job) bool

type TxCallback func(q Queue) error