Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewTypedRateLimitingQueueWithConfig (0.38 sec)

  1. pkg/kubelet/cm/dra/plugin/noderesources.go

    	ctx = klog.NewContext(ctx, logger)
    
    	c := &nodeResourcesController{
    		ctx:        ctx,
    		kubeClient: kubeClient,
    		getNode:    getNode,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "node_resource_slices"},
    		),
    		activePlugins: make(map[string]*activePlugin),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 20:12:53 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set.go

    			history.NewHistory(kubeClient, revInformer.Lister()),
    		),
    		pvcListerSynced: pvcInformer.Informer().HasSynced,
    		revListerSynced: revInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "statefulset"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  3. pkg/controller/endpointslice/endpointslice_controller.go

    		// such as an update to a Service or Deployment. A more significant
    		// rate limit back off here helps ensure that the Controller does not
    		// overwhelm the API Server.
    		serviceQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.NewTypedMaxOfRateLimiter(
    				workqueue.NewTypedItemExponentialFailureRateLimiter[string](defaultSyncBackOff, maxSyncBackOff),
    				// 10 qps, 100 bucket size. This is only for retry speed and its
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  4. pkg/controller/cronjob/cronjob_controllerv2.go

    	logger := klog.FromContext(ctx)
    	eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
    
    	jm := &ControllerV2{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "cronjob",
    			},
    		),
    		kubeClient:  kubeClient,
    		broadcaster: eventBroadcaster,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  5. pkg/controller/resourceclaim/controller.go

    		claimsSynced:        claimInformer.Informer().HasSynced,
    		templateLister:      templateInformer.Lister(),
    		templatesSynced:     templateInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resource_claim"},
    		),
    		deletedObjects: newUIDCache(maxUIDCacheEntries),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top