Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pkg/controller/bootstrap/bootstrapsigner.go

    		configMapLister:    configMaps.Lister(),
    		configMapSynced:    configMaps.Informer().HasSynced,
    		syncQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "bootstrap_signer_queue",
    			},
    		),
    	}
    
    	configMaps.Informer().AddEventHandlerWithResyncPeriod(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    		configmapKey:       key,
    		configmapLister:    configmapLister,
    		configMapInformer:  uncastConfigmapInformer,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: fmt.Sprintf("DynamicConfigMapCABundle-%s", purpose)},
    		),
    		preRunCaches: []cache.InformerSynced{uncastConfigmapInformer.HasSynced},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
Back to top