Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 24 for DefaultTypedControllerRateLimiter (0.39 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go

    		crdClient: crdClient,
    		crdLister: crdInformer.Lister(),
    		crdSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubernetes_api_approval_conformant_condition_controller"},
    		),
    		lastSeenProtectedAnnotation: map[string]string{},
    	}
    
    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. pkg/controller/storageversionmigrator/resourceversion.go

    		svmListers:      svmInformer.Lister(),
    		svmSynced:       svmInformer.Informer().HasSynced,
    		mapper:          mapper,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: ResourceVersionControllerName},
    		),
    	}
    
    	_, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    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/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    	c := &ConditionController{
    		crdClient: crdClient,
    		crdLister: crdInformer.Lister(),
    		crdSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "non_structural_schema_condition_controller"},
    		),
    		lastSeenGeneration: map[string]int64{},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    	c := &Controller{
    		crdLister:  crdInformer.Lister(),
    		crdsSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_openapi_v3_controller"},
    		),
    		specsByGVandName: map[schema.GroupVersion]map[string]*spec3.OpenAPI{},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    		apiServiceRegistration: apiServiceRegistration,
    		syncedInitialSet:       make(chan struct{}),
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "crd_autoregistration_controller"},
    		),
    	}
    	c.syncHandler = c.handleVersionUpdate
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K 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{
    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

    	}
    	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 {
    		return nil, err
    	}
    
    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/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)
  9. pkg/controller/storageversionmigrator/storageversionmigrator.go

    		svmSynced:              svmInformer.Informer().HasSynced,
    		restMapper:             mapper,
    		dependencyGraphBuilder: dependencyGraphBuilder,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: controllerName},
    		),
    	}
    
    	_, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. 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)
Back to top