Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 32 of 32 for NewTypedRateLimitingQueueWithConfig (0.42 sec)

  1. 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)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    	// Start with longish delay because conflicts will be between
    	// different processes, so take some time to go away.
    	cfgCtlr.configQueue = workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.NewTypedItemExponentialFailureRateLimiter[int](200*time.Millisecond, 8*time.Hour),
    		workqueue.TypedRateLimitingQueueConfig[int]{Name: "priority_and_fairness_config_queue"},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
Back to top