Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 58 for DefaultTypedControllerRateLimiter (0.48 sec)

  1. pkg/controller/deployment/progress_test.go

    			expected: time.Duration(0),
    		},
    	}
    
    	dc := &DeploymentController{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "doesnt_matter",
    			},
    		),
    	}
    	dc.enqueueDeployment = dc.enqueue
    
    	for _, test := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    	c := &Controller{
    		crdLister:  crdInformer.Lister(),
    		crdsSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_openapi_controller"},
    		),
    		specsByName: map[string]*specCache{},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  3. pkg/controller/garbagecollector/graph_builder.go

    	attemptToDelete := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    		workqueue.TypedRateLimitingQueueConfig[*node]{
    			Name: "garbage_collector_attempt_to_delete",
    		},
    	)
    	attemptToOrphan := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    		workqueue.TypedRateLimitingQueueConfig[*node]{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    		resourceManager: resourceManager,
    		crdLister:       crdInformer.Lister(),
    		crdsSynced:      crdInformer.Informer().HasSynced,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "DiscoveryController"},
    		),
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  5. pkg/controller/ttlafterfinished/ttlafterfinished_controller.go

    		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)
    	jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 23:59:28 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. pkg/controller/resourcequota/resource_quota_monitor.go

    		informersStarted: informersStarted,
    		informerFactory:  informerFactory,
    		ignoredResources: ignoredResources,
    		resourceChanges: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[*event](),
    			workqueue.TypedRateLimitingQueueConfig[*event]{Name: "resource_quota_controller_resource_changes"},
    		),
    		resyncPeriod:      resyncPeriod,
    		replenishmentFunc: replenishmentFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		crdLister:      crdInformer.Lister(),
    		crdSynced:      crdInformer.Informer().HasSynced,
    		crClientGetter: crClientGetter,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_finalizer"},
    		),
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    	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"},
    		),
    	}
    
    	informerIndexer := crdInformer.Informer().GetIndexer()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. pkg/registry/core/service/ipallocator/cidrallocator.go

    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    		ipAddressInformer: ipAddressInformer,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: ControllerName},
    		),
    		internalStopCh: make(chan struct{}),
    		tree:           iptree.New[*Allocator](),
    		ipFamily:       family,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. 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,
    		csiMigratedPluginManager: csiMigratedPluginManager,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top