Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 62 for TypedRateLimitingQueueConfig (0.48 sec)

  1. pkg/controller/storageversionmigrator/storageversionmigrator.go

    		restMapper:             mapper,
    		dependencyGraphBuilder: dependencyGraphBuilder,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: controllerName},
    		),
    	}
    
    	_, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			svmController.addSVM(logger, obj)
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go

    	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)
  3. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go

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

    			workqueue.DefaultTypedControllerRateLimiter[serviceAccountQueueKey](),
    			workqueue.TypedRateLimitingQueueConfig[serviceAccountQueueKey]{Name: "serviceaccount_tokens_service"},
    		),
    		syncSecretQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[secretQueueKey](),
    			workqueue.TypedRateLimitingQueueConfig[secretQueueKey]{Name: "serviceaccount_tokens_service"},
    		),
    
    		maxRetries: maxRetries,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    		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)
  6. pkg/controller/ttl/ttl_controller.go

    	ttlc := &Controller{
    		kubeClient: kubeClient,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttlcontroller"},
    		),
    	}
    	logger := klog.FromContext(ctx)
    	nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			ttlc.addNode(logger, obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go

    	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 {
    		return nil, err
    	}
    
    	return ret, 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)
  8. pkg/controller/volume/ephemeral/controller.go

    		pvcLister:  pvcInformer.Lister(),
    		pvcsSynced: pvcInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ephemeral_volume"},
    		),
    	}
    
    	ephemeralvolumemetrics.RegisterMetrics()
    
    	eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
    	eventBroadcaster.StartLogging(klog.Infof)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go

    		clientCA:      clientCA,
    		servingCert:   servingCert,
    		sniCerts:      sniCerts,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "DynamicServingCertificateController"},
    		),
    		eventRecorder: eventRecorder,
    	}
    
    	return c
    }
    
    // GetConfigForClient is an implementation of tls.Config.GetConfigForClient
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller.go

    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resourcequota_primary"},
    		),
    		missingUsageQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resourcequota_priority"},
    		),
    		resyncPeriod: options.ResyncPeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top