queue

Documentation

Index

• type Queue
  • func NewQueue(name string) Queue
  • func (q *Queue) Enqueue(obj interface{})
  • func (q *Queue) ProcessNextItem(sync syncFunc) bool
  • func (q *Queue) ShutDown()

Types

type Queue

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

func NewQueue

func NewQueue(name string) Queue

func (*Queue) Enqueue

func (q *Queue) Enqueue(obj interface{})

func (*Queue) ProcessNextItem

func (q *Queue) ProcessNextItem(sync syncFunc) bool

ProcessNextItem will read a single item from the workqueue and attempt to process it, by calling sync function.

func (*Queue) ShutDown

func (q *Queue) ShutDown()