- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 142 for workqueue (0.24 sec)
-
pkg/controller/bootstrap/tokencleaner.go
secretLister: secrets.Lister(), secretSynced: secrets.Informer().HasSynced, tokenSecretNamespace: options.TokenSecretNamespace, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "token_cleaner", }, ), } secrets.Informer().AddEventHandlerWithResyncPeriod(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
e := &ServiceAccountsController{ client: cl, serviceAccountsToEnsure: options.ServiceAccounts, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "serviceaccount"}, ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
) *ConditionController { 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) -
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) -
platforms/jvm/code-quality/src/main/groovy/org/gradle/api/plugins/quality/CodeNarc.java
setConfig(getProject().getResources().getText().fromFile(configFile)); } @TaskAction public void run() { WorkQueue workQueue = getWorkerExecutor().processIsolation(spec -> configureForkOptions(spec.getForkOptions())); workQueue.submit(CodeNarcAction.class, this::setupParameters); } private void setupParameters(CodeNarcActionParameters parameters) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jul 19 14:14:11 UTC 2023 - 7.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/process/ProcessInTaskIntegrationTest.groovy
@Inject abstract public WorkerExecutor getWorkerExecutor(); @TaskAction public void exec() { WorkQueue workQueue = getWorkerExecutor().noIsolation(); workQueue.submit(SneakyAction.class, parameters -> {}) } } def sneakyTask = tasks.register("sneakyTask", SneakyTask) {}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 12.5K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
metadataClient: metadataClient, 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) -
pkg/controller/tainteviction/taint_eviction.go
} pods = append(pods, pod) } return pods, nil }, taintedNodes: make(map[string][]v1.Taint), nodeUpdateQueue: workqueue.NewTypedWithConfig(workqueue.TypedQueueConfig[nodeUpdateItem]{Name: "noexec_taint_node"}), podUpdateQueue: workqueue.NewTypedWithConfig(workqueue.TypedQueueConfig[podUpdateItem]{Name: "noexec_taint_pod"}), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
secretSynced: secrets.Informer().HasSynced, 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)