- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for NewTypedRateLimitingQueueWithConfig (1.07 sec)
-
pkg/kubelet/logs/container_log_manager_test.go
MaxSize: testMaxSize, MaxFiles: testMaxFiles, }, osInterface: container.RealOS{}, clock: testingclock.NewFakeClock(now), mutex: sync.Mutex{}, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"}, ), maxWorkers: 10,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
ec := &EstablishingController{ crdClient: crdClient, crdLister: crdInformer.Lister(), crdSynced: crdInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "crdEstablishing"}, ), } ec.syncFn = ec.sync return ec }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
storageVersionSynced: storageVersionInformer.Informer().HasSynced, leaseQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "storage_version_garbage_collector_leases"}, ), storageVersionQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
c := &Controller{ policyInformer: policyInformer, policyQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: ControllerName}, ), policyClient: policyClient, typeChecker: typeChecker, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
options.FieldSelector = fields.OneTermEqualSelector("metadata.name", ConfigMapName).String() }) c := &Controller{ configMapClient: cs.CoreV1(), queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "legacy_token_tracking_controller"}, ), configMapInformer: informer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
) *CertificateController { logger := klog.FromContext(ctx) cc := &CertificateController{ name: name, kubeClient: kubeClient, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.NewTypedMaxOfRateLimiter[string]( workqueue.NewTypedItemExponentialFailureRateLimiter[string](200*time.Millisecond, 1000*time.Second),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
e := &Publisher{ client: cl, rootCA: rootCA, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "root_ca_cert_publisher", }, ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
clusterRoleClient: clusterRoleClient, clusterRoleLister: clusterRoleInformer.Lister(), clusterRolesSynced: clusterRoleInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "ClusterRoleAggregator", }, ), } c.syncHandler = c.syncClusterRole
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
} name := fmt.Sprintf("%s::%s::%s", purpose, certFile, keyFile) ret := &DynamicCertKeyPairContent{ name: name, certFile: certFile, keyFile: keyFile, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: fmt.Sprintf("DynamicCABundle-%s", purpose)}, ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
func NewPVProtectionController(logger klog.Logger, pvInformer coreinformers.PersistentVolumeInformer, cl clientset.Interface) *Controller { e := &Controller{ client: cl, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "pvprotection"}, ), } e.pvLister = pvInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0)