Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for DefaultTypedControllerRateLimiter (0.23 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go

    	klog.Infof("starting %s", c.options.Name)
    	defer klog.Infof("stopping %s", c.options.Name)
    
    	c.queue = workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[string](),
    		workqueue.TypedRateLimitingQueueConfig[string]{Name: c.options.Name},
    	)
    
    	// Forcefully shutdown workqueue. Drop any enqueued items.
    	// Important to do this in a `defer` at the start of `Run`.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go

    		lastLoadedEncryptionConfigHash: configContentHash,
    		dynamicTransformers:            dynamicTransformers,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: name},
    		),
    		apiServerID: apiServerID,
    		getEncryptionConfigHash: func(_ context.Context, filepath string) (string, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  3. pkg/controller/volume/ephemeral/controller.go

    		podSynced:  podInformer.Informer().HasSynced,
    		pvcLister:  pvcInformer.Lister(),
    		pvcsSynced: pvcInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ephemeral_volume"},
    		),
    	}
    
    	ephemeralvolumemetrics.RegisterMetrics()
    
    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. 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)
Back to top