Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 25 of 25 for NewTypedRateLimitingQueueWithConfig (0.77 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    		configmapNamespace: namespace,
    		configmapName:      name,
    		configmapKey:       key,
    		configmapLister:    configmapLister,
    		configMapInformer:  uncastConfigmapInformer,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: fmt.Sprintf("DynamicConfigMapCABundle-%s", purpose)},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. pkg/controller/ttl/ttl_controller.go

    func NewTTLController(ctx context.Context, nodeInformer informers.NodeInformer, kubeClient clientset.Interface) *Controller {
    	ttlc := &Controller{
    		kubeClient: kubeClient,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttlcontroller"},
    		),
    	}
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go

    		return nil, fmt.Errorf("missing filename for ca bundle")
    	}
    	name := fmt.Sprintf("%s::%s", purpose, filename)
    
    	ret := &DynamicFileCAContent{
    		name:     name,
    		filename: filename,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: fmt.Sprintf("DynamicCABundle-%s", purpose)},
    		),
    	}
    	if err := ret.loadCABundle(); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. pkg/controller/volume/ephemeral/controller.go

    		podIndexer: podInformer.Informer().GetIndexer(),
    		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)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    func NewController(crdInformer informers.CustomResourceDefinitionInformer) *Controller {
    	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