workqueue

Documentation

Index

• type DelayingInterface
  • func NewDelayingQueue() DelayingInterface
  • func NewNamedDelayingQueue(name string) DelayingInterface

Types

type DelayingInterface

type DelayingInterface interface {
	workqueue.Interface
	// AddAfter adds an item to the workqueue after the indicated duration has passed
	AddAfter(item interface{}, duration time.Duration)
}

DelayingInterface is an Interface that can Add an item at a later time. This makes it easier to requeue items after failures without ending up in a hot-loop.

func NewDelayingQueue

func NewDelayingQueue() DelayingInterface

NewDelayingQueue constructs a new workqueue with delayed queuing ability

func NewNamedDelayingQueue

func NewNamedDelayingQueue(name string) DelayingInterface