Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 62 for NewTypedRateLimitingQueueWithConfig (0.63 sec)

  1. pkg/controller/deployment/progress_test.go

    			nowFn:    func() time.Time { return metav1.Date(2017, 2, 15, 18, 51, 00, 00, time.UTC).Time },
    			expected: time.Duration(0),
    		},
    	}
    
    	dc := &DeploymentController{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "doesnt_matter",
    			},
    		),
    	}
    	dc.enqueueDeployment = dc.enqueue
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. 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)
  3. pkg/controller/garbagecollector/graph_builder.go

    	attemptToDelete := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    		workqueue.TypedRateLimitingQueueConfig[*node]{
    			Name: "garbage_collector_attempt_to_delete",
    		},
    	)
    	attemptToOrphan := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

    		groupHeadersKey:        groupHeadersKey,
    		extraHeaderPrefixesKey: extraHeaderPrefixesKey,
    		allowedClientNamesKey:  allowedClientNamesKey,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "RequestHeaderAuthRequestController"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    		groupHandler:    groupHandler,
    		resourceManager: resourceManager,
    		crdLister:       crdInformer.Lister(),
    		crdsSynced:      crdInformer.Informer().HasSynced,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "DiscoveryController"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    	c := &CRDFinalizer{
    		crdClient:      crdClient,
    		crdLister:      crdInformer.Lister(),
    		crdSynced:      crdInformer.Informer().HasSynced,
    		crClientGetter: crClientGetter,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_finalizer"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    ) *NamingConditionController {
    	c := &NamingConditionController{
    		crdClient: crdClient,
    		crdLister: crdInformer.Lister(),
    		crdSynced: crdInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_naming_condition_controller"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. pkg/controller/ttlafterfinished/ttlafterfinished_controller.go

    	metrics.Register()
    
    	tc := &Controller{
    		client:   client,
    		recorder: eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "ttl-after-finished-controller"}),
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "ttl_jobs_to_delete"},
    		),
    	}
    
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 23:59:28 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. pkg/controller/resourcequota/resource_quota_monitor.go

    	return &QuotaMonitor{
    		informersStarted: informersStarted,
    		informerFactory:  informerFactory,
    		ignoredResources: ignoredResources,
    		resourceChanges: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[*event](),
    			workqueue.TypedRateLimitingQueueConfig[*event]{Name: "resource_quota_controller_resource_changes"},
    		),
    		resyncPeriod:      resyncPeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. pkg/registry/core/service/ipallocator/cidrallocator.go

    		ipAddressLister:   ipAddressInformer.Lister(),
    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    		ipAddressInformer: ipAddressInformer,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: ControllerName},
    		),
    		internalStopCh: make(chan struct{}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top