queue

Documentation

Index

• func SetRequeued(name string, val float64)
• type Queue
  • func NewQueue(name string, reconcileFunc queueReconcileFunc) *Queue
  • func (q *Queue) Add(obj interface{})
  • func (q *Queue) Run()
  • func (q *Queue) Stop()

Functions

func SetRequeued

func SetRequeued(name string, val float64)

SetRequeued updates the number of requeued items

Types

type Queue

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

queue provides a rate-limited queue that processes items with a provided reconcile function

func NewQueue

func NewQueue(name string, reconcileFunc queueReconcileFunc) *Queue

newQueue returns a new queue

func (*Queue) Add

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

Add an item to the queue, where that item is an object that implements meta.Interface.

func (*Queue) Run

func (q *Queue) Run()

Run processes items from the queue as they're added

func (*Queue) Stop

func (q *Queue) Stop()

Stop causes the queue to shut down