Versions in this module Expand all Collapse all v2 v2.4.1 Jul 27, 2024 Changes in this version + var DummyMetricsRecorder = dummy(0) + var ErrControllerNotValid = errors.New("controller not valid") + type Config struct + ConcurrentWorkers int + DisableResync bool + Handler Handler + LeaderElector leaderelection.Runner + Logger log.Logger + MetricsRecorder MetricsRecorder + Name string + ProcessingJobRetries int + ResyncInterval time.Duration + Retriever Retriever + type Controller interface + Run func(ctx context.Context) error + func New(cfg *Config) (Controller, error) + type Handler interface + Handle func(context.Context, runtime.Object) error + type HandlerFunc func(context.Context, runtime.Object) error + func (h HandlerFunc) Handle(ctx context.Context, obj runtime.Object) error + type MetricsRecorder interface + IncResourceEventQueued func(ctx context.Context, controller string, isRequeue bool) + ObserveResourceInQueueDuration func(ctx context.Context, controller string, queuedAt time.Time) + ObserveResourceProcessingDuration func(ctx context.Context, controller string, success bool, ...) + RegisterResourceQueueLengthFunc func(controller string, f func(context.Context) int) error + type Retriever interface + List func(ctx context.Context, options metav1.ListOptions) (runtime.Object, error) + Watch func(ctx context.Context, options metav1.ListOptions) (watch.Interface, error) + func MustRetrieverFromListerWatcher(lw cache.ListerWatcher) Retriever + func RetrieverFromListerWatcher(lw cache.ListerWatcher) (Retriever, error)
Go to main page