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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnqueueObjectWithKey ¶
EnqueueObjectWithKey is used to enqueue object key.
func EnqueueObjectWithKeyName ¶
EnqueueObjectWithKeyName is used to enqueue object key name.
func EnqueueObjectWithKeyNamespace ¶
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.