Versions in this module Expand all Collapse all v0 v0.2.0 Oct 27, 2022 Changes in this version + const AddsKey + const DepthKey + const LABEL_HCG_MANAGED + const LongestRunningProcessorKey + const QueueLatencyKey + const RetriesKey + const UnfinishedWorkKey + const WorkDurationKey + const WorkQueueSubsystem + type Controller struct + Logger logr.Logger + Name string + Process func(context.Context, string) error + Queue workqueue.RateLimitingInterface + func NewController(name string, queue workqueue.RateLimitingInterface) *Controller + func (c *Controller) Enqueue(obj interface{}) + func (c *Controller) EnqueueAfter(obj interface{}, dur time.Duration) + func (c *Controller) Start(ctx context.Context, numThreads int) + type ControllerConfig struct + NameSuffix string + func (c *ControllerConfig) GetName(defaultName string) string
Go to main page