Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 142 for workqueue (0.13 sec)

  1. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    		crdSynced:              crdinformer.Informer().HasSynced,
    		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)
  2. pkg/controller/endpointslice/endpointslice_controller.go

    		// overwhelm the API Server.
    		serviceQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.NewTypedMaxOfRateLimiter(
    				workqueue.NewTypedItemExponentialFailureRateLimiter[string](defaultSyncBackOff, maxSyncBackOff),
    				// 10 qps, 100 bucket size. This is only for retry speed and its
    				// only the overall factor (not per item).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/tokens_controller.go

    		syncServiceAccountQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[serviceAccountQueueKey](),
    			workqueue.TypedRateLimitingQueueConfig[serviceAccountQueueKey]{Name: "serviceaccount_tokens_service"},
    		),
    		syncSecretQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[secretQueueKey](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip.go

    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    		cidrQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "servicecidrs"},
    		),
    		svcQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "services"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    		configmapName:      name,
    		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)
  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)
    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/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{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go

    		filePath:                       filePath,
    		lastLoadedEncryptionConfigHash: configContentHash,
    		dynamicTransformers:            dynamicTransformers,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: name},
    		),
    		apiServerID: apiServerID,
    		getEncryptionConfigHash: func(_ context.Context, filepath string) (string, error) {
    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/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		crdClient:      crdClient,
    		crdLister:      crdInformer.Lister(),
    		crdSynced:      crdInformer.Informer().HasSynced,
    		crClientGetter: crClientGetter,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "crd_finalizer"},
    		),
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
Back to top