Versions in this module Expand all Collapse all v1 v1.0.0 Feb 4, 2026 Changes in this version + var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + type PeriodicTaskQueueWithMultipleWorkers struct + func NewPeriodicTaskQueueWithMultipleWorkers(name, resource string, numWorkers int, ...) *PeriodicTaskQueueWithMultipleWorkers + func (t *PeriodicTaskQueueWithMultipleWorkers) Enqueue(objs ...any) + func (t *PeriodicTaskQueueWithMultipleWorkers) Len() int + func (t *PeriodicTaskQueueWithMultipleWorkers) NumRequeues(obj any) int + func (t *PeriodicTaskQueueWithMultipleWorkers) Run() + func (t *PeriodicTaskQueueWithMultipleWorkers) Shutdown() + func (t *PeriodicTaskQueueWithMultipleWorkers) ShuttingDown() bool + type TaskQueue interface + Enqueue func(objs ...any) + Len func() int + NumRequeues func(obj any) int + Run func() + Shutdown func() + ShuttingDown func() bool
Go to main page