controller

Documentation

Index

• func DelayingWorker[T comparable](queue workqueue.TypedRateLimitingInterface[T], syncer func(T) error, ...) func()
• func RateLimitedWorker[T comparable](queue workqueue.TypedRateLimitingInterface[T], syncer func(T) error, ...) func()

Functions

func DelayingWorker

func DelayingWorker[T comparable](queue workqueue.TypedRateLimitingInterface[T], syncer func(T) 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[T comparable](queue workqueue.TypedRateLimitingInterface[T], syncer func(T) 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.