- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for NewTypedRateLimitingQueueWithConfig (0.43 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
c := &CRDFinalizer{ crdClient: crdClient, crdLister: crdInformer.Lister(), crdSynced: crdInformer.Informer().HasSynced, crClientGetter: crClientGetter, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_finalizer"}, ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
) *NamingConditionController { c := &NamingConditionController{ crdClient: crdClient, crdLister: crdInformer.Lister(), crdSynced: crdInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_naming_condition_controller"}, ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
ipAddressLister: ipAddressInformer.Lister(), ipAddressSynced: ipAddressInformer.Informer().HasSynced, ipAddressInformer: ipAddressInformer, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: ControllerName}, ), internalStopCh: make(chan struct{}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
metrics.Register() tc := &Controller{ client: client, recorder: eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "ttl-after-finished-controller"}), queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttl_jobs_to_delete"}, ), } logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
return &QuotaMonitor{ informersStarted: informersStarted, informerFactory: informerFactory, ignoredResources: ignoredResources, resourceChanges: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[*event](), workqueue.TypedRateLimitingQueueConfig[*event]{Name: "resource_quota_controller_resource_changes"}, ), resyncPeriod: resyncPeriod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
expc := &expandController{ kubeClient: kubeClient, pvcLister: pvcInformer.Lister(), pvcsSynced: pvcInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "volume_expand"}, ), translator: translator,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
e := &Controller{ client: cl, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "pvcprotection"}, ), } e.pvcLister = pvcInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
configMapClient: kubeClient.CoreV1(), namespaceClient: kubeClient.CoreV1(), queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "cluster_authentication_trust_controller"}, ),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager.go
policy: LogRotatePolicy{ MaxSize: parsedMaxSize, MaxFiles: maxFiles, }, clock: clock.RealClock{}, mutex: sync.Mutex{}, maxWorkers: maxWorkers, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"}, ), monitoringPeriod: monitorInterval, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 15K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
clock clock.WithTicker, stalePodDisruptionTimeout time.Duration, ) *DisruptionController { logger := klog.FromContext(ctx) dc := &DisruptionController{ kubeClient: kubeClient, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ DelayingQueue: workqueue.NewTypedDelayingQueueWithConfig(workqueue.TypedDelayingQueueConfig[string]{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0)