worker

Documentation

Index

• type Instance
  • func New(w workqueue.RateLimitingInterface) *Instance
  • func (w *Instance) Enqueue(obj interface{})

Types

type Instance

type Instance struct {
	workqueue.RateLimitingInterface
}

Instance is a rate limited work queue. This is used to queue work to be processed instead of performing it as soon as a change happens. This means we can ensure we only process a fixed amount of resources at a time, and makes it easy to ensure we are never processing the same item simultaneously in two different workers.

func New

func New(w workqueue.RateLimitingInterface) *Instance

func (*Instance) Enqueue

func (w *Instance) Enqueue(obj interface{})

enqueueScenario takes a Foo resource and converts it into a namespace/name string which is then put onto the work queue. This method should *not* be passed resources of any type other than Foo.