Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 62 for NewTypedRateLimitingQueueWithConfig (0.38 sec)

  1. pkg/controller/bootstrap/tokencleaner.go

    		client:               cl,
    		secretLister:         secrets.Lister(),
    		secretSynced:         secrets.Informer().HasSynced,
    		tokenSecretNamespace: options.TokenSecretNamespace,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "token_cleaner",
    			},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. pkg/controller/serviceaccount/serviceaccounts_controller.go

    	e := &ServiceAccountsController{
    		client:                  cl,
    		serviceAccountsToEnsure: options.ServiceAccounts,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "serviceaccount"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go

    	c := &KubernetesAPIApprovalPolicyConformantConditionController{
    		crdClient: crdClient,
    		crdLister: crdInformer.Lister(),
    		crdSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubernetes_api_approval_conformant_condition_controller"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip.go

    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    		cidrQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "servicecidrs"},
    		),
    		svcQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. pkg/controller/storageversionmigrator/resourceversion.go

    		discoveryClient: discoveryClient,
    		metadataClient:  metadataClient,
    		svmListers:      svmInformer.Lister(),
    		svmSynced:       svmInformer.Informer().HasSynced,
    		mapper:          mapper,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: ResourceVersionControllerName},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    ) *ConditionController {
    	c := &ConditionController{
    		crdClient: crdClient,
    		crdLister: crdInformer.Lister(),
    		crdSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "non_structural_schema_condition_controller"},
    		),
    		lastSeenGeneration: map[string]int64{},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    func NewController(crdInformer informers.CustomResourceDefinitionInformer) *Controller {
    	c := &Controller{
    		crdLister:  crdInformer.Lister(),
    		crdsSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_openapi_v3_controller"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. pkg/controller/namespace/namespace_controller.go

    	finalizerToken v1.FinalizerName) *NamespaceController {
    
    	// create the controller so we can inject the enqueue function
    	namespaceController := &NamespaceController{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			nsControllerRateLimiter(),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "namespace",
    			},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. pkg/controller/bootstrap/bootstrapsigner.go

    		secretSynced:       secrets.Informer().HasSynced,
    		configMapLister:    configMaps.Lister(),
    		configMapSynced:    configMaps.Informer().HasSynced,
    		syncQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "bootstrap_signer_queue",
    			},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    		crdSynced:              crdinformer.Informer().HasSynced,
    		apiServiceRegistration: apiServiceRegistration,
    		syncedInitialSet:       make(chan struct{}),
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "crd_autoregistration_controller"},
    		),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top