queue

Documentation

Index

• type Instance
  • func NewQueue(errorDelay time.Duration) Instance
• type LKQueue
  • func NewLKQueue() *LKQueue
  • func (q *LKQueue) Dequeue() interface{}
  • func (q *LKQueue) Enqueue(v interface{})
• type Task

Types

type Instance

type Instance interface {
	// Push a task
	Push(task Task)
	// Run the loop until a signal on the channel
	Run(<-chan struct{})
}

Instance of work tickets processed using a rate-limiting loop

func NewQueue

func NewQueue(errorDelay time.Duration) Instance

type LKQueue

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

LKQueue is a lock-free unbounded queue.

func NewLKQueue

func NewLKQueue() *LKQueue

func (*LKQueue) Dequeue

func (q *LKQueue) Dequeue() interface{}

Dequeue removes and returns the value at the head of the queue. It returns nil if the queue is empty.

func (*LKQueue) Enqueue

func (q *LKQueue) Enqueue(v interface{})

Enqueue puts the given value v at the tail of the queue.

type Task

type Task func() error