memory

Documentation

Index

• func New() queue.Broker
• func NewFinite(finite bool) queue.Broker
• type Acknowledger
  • func (*Acknowledger) Ack() error
  • func (a *Acknowledger) Reject(requeue bool) error
• type Broker
  • func (b *Broker) Close() error
  • func (b *Broker) Queue(name string) (queue.Queue, error)
• type JobIter
  • func (i *JobIter) Close() error
  • func (i *JobIter) Next() (*queue.Job, error)
• type Queue
  • func (q *Queue) Consume(_ int) (queue.JobIter, error)
  • func (q *Queue) Publish(j *queue.Job) 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

Functions

func New

func New() queue.Broker

New creates a new Broker for an in-memory queue.

func NewFinite

func NewFinite(finite bool) queue.Broker

NewFinite creates a new Broker for an in-memory queue. The argument specifies if the JobIter stops on EOF or not.

Types

type Acknowledger

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

Acknowledger implements a queue.Acknowledger interface.

func (*Acknowledger) Ack

func (*Acknowledger) Ack() error

Ack is called when the Job has finished.

func (*Acknowledger) Reject

func (a *Acknowledger) Reject(requeue bool) error

Reject is called when the Job has errored. The argument indicates whether the Job should be put back in queue or not. 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 is a in-memory implementation of Broker.

func (*Broker) Close

func (b *Broker) Close() error

Close closes the connection in the Broker.

func (*Broker) Queue

func (b *Broker) Queue(name string) (queue.Queue, error)

Queue returns the queue with the given name.

type JobIter

type JobIter struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

JobIter implements a queue.JobIter interface.

func (*JobIter) Close

func (i *JobIter) Close() error

Close closes the iter.

func (*JobIter) Next

func (i *JobIter) Next() (*queue.Job, error)

Next returns the next job in the iter.

type Queue

type Queue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Queue implements a queue.Queue interface.

func (*Queue) Consume

func (q *Queue) Consume(_ int) (queue.JobIter, error)

Consume implements Queue. MemoryQueues have infinite advertised window.

func (*Queue) Publish

func (q *Queue) Publish(j *queue.Job) error

Publish publishes a Job to the queue.

func (*Queue) PublishDelayed

func (q *Queue) PublishDelayed(j *queue.Job, delay time.Duration) error

PublishDelayed publishes a Job to the queue with a given delay.

func (*Queue) RepublishBuried

func (q *Queue) RepublishBuried(conditions ...queue.RepublishConditionFunc) error

RepublishBuried implements the Queue interface.

func (*Queue) Transaction

func (q *Queue) Transaction(txcb queue.TxCallback) error

Transaction calls the given callback inside a transaction.