Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DelayingWorker ¶
func DelayingWorker(queue workqueue.RateLimitingInterface, syncer func(string) error, duration time.Duration, maxRetry int) func()
DelayingWorker returns a long-running worker function that will re-queue the item after the given duration has passed if an error happens when processing it.
func RateLimitedWorker ¶
func RateLimitedWorker(queue workqueue.RateLimitingInterface, syncer func(string) error, maxRetry int) func()
RateLimitedWorker returns a long-running worker function that will re-queue the item by AddRateLimited function if an error happens when processing it.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.