Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithRateLimiter (0.1 sec)

  1. pkg/webhooks/validation/controller/controller.go

    		// the validation controller waits for its own service to be ready, so typically this takes a few seconds
    		// before we are ready; using FastSlow means we tend to always take the Slow time (1min).
    		controllers.WithRateLimiter(workqueue.NewItemExponentialFailureRateLimiter(100*time.Millisecond, 1*time.Minute)))
    
    	c.webhooks = kclient.NewFiltered[*kubeApiAdmission.ValidatingWebhookConfiguration](client, kclient.Filter{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 16:52:19 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. pkg/kubelet/server/server.go

    // ListenAndServePodResources initializes a gRPC server to serve the PodResources service
    func ListenAndServePodResources(endpoint string, providers podresources.PodResourcesProviders) {
    	server := grpc.NewServer(apisgrpc.WithRateLimiter("podresources", podresources.DefaultQPS, podresources.DefaultBurstTokens))
    
    	podresourcesapiv1alpha1.RegisterPodResourcesListerServer(server, podresources.NewV1alpha1PodResourcesServer(providers))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
Back to top