Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 142 for workqueue (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top