worker

Documentation

Index

• Constants
• func Run(queue workqueue.RateLimitingInterface, resourceType string, maxRetries int, ...)

Constants

const (
	// DefaultMaxRetries is the default value for max number of re-queues when running worker.Run
	DefaultMaxRetries = 15
)

Functions

func Run

func Run(queue workqueue.RateLimitingInterface, resourceType string, maxRetries int, forgetAfterSuccess bool, reconciler func(key string) error, stopCh <-chan struct{}, waitGroup *sync.WaitGroup)

Run creates and runs a worker routine that just processes items in the specified queue. The worker will run until stopCh is closed. The worker will be added to the wait group when started and marked done when finished.