queue

Documentation

Index

• func EnqueueObjectWithKey(obj interface{}, queue workqueue.Interface)
• func EnqueueObjectWithKeyName(obj interface{}, queue workqueue.Interface)
• func EnqueueObjectWithKeyNamespace(obj interface{}, queue workqueue.Interface)
• func HandleQueueItem(ctx context.Context, queueID string, q workqueue.RateLimitingInterface, ...) bool
• func HandleQueueItemWithAlwaysRetry(ctx context.Context, queueID string, q workqueue.RateLimitingInterface, ...) bool
• func HandleQueueItemWithoutRetry(ctx context.Context, queueID string, q workqueue.Interface, ...) bool

Functions

func EnqueueObjectWithKey

func EnqueueObjectWithKey(obj interface{}, queue workqueue.Interface)

EnqueueObjectWithKey is used to enqueue object key.

func EnqueueObjectWithKeyName

func EnqueueObjectWithKeyName(obj interface{}, queue workqueue.Interface)

EnqueueObjectWithKeyName is used to enqueue object key name.

func EnqueueObjectWithKeyNamespace

func EnqueueObjectWithKeyNamespace(obj interface{}, queue workqueue.Interface)

EnqueueObjectWithKeyNamespace is used to enqueue object key namespace.

func HandleQueueItem

func HandleQueueItem(ctx context.Context, queueID string, q workqueue.RateLimitingInterface, handler queueHandler, maxRetries int) bool

HandleQueueItem is used to handle queue item with retrying when error happened.

func HandleQueueItemWithAlwaysRetry

func HandleQueueItemWithAlwaysRetry(ctx context.Context, queueID string, q workqueue.RateLimitingInterface, handler queueHandler) bool

HandleQueueItemWithAlwaysRetry is used to handle queue item with retrying when error happened.

func HandleQueueItemWithoutRetry

func HandleQueueItemWithoutRetry(ctx context.Context, queueID string, q workqueue.Interface, handler queueHandler) bool

HandleQueueItemWithoutRetry is used to handle queue item without retrying.