Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 32 of 32 for TypedRateLimitingQueueConfig (0.34 sec)

  1. pkg/controller/resourceclaim/controller.go

    		templatesSynced:     templateInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resource_claim"},
    		),
    		deletedObjects: newUIDCache(maxUIDCacheEntries),
    	}
    
    	metrics.RegisterMetrics()
    
    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

    	cfgCtlr.configQueue = workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.NewTypedItemExponentialFailureRateLimiter[int](200*time.Millisecond, 8*time.Hour),
    		workqueue.TypedRateLimitingQueueConfig[int]{Name: "priority_and_fairness_config_queue"},
    	)
    	// ensure the data structure reflects the mandatory config
    	cfgCtlr.lockAndDigestConfigObjects(nil, nil)
    	fci := config.InformerFactory.Flowcontrol().V1()
    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