- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 142 for workqueue (0.37 sec)
-
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) -
platforms/documentation/docs/src/snippets/workerApi/workerDaemon/kotlin/build.gradle.kts
@get:OutputDirectory abstract val outputDir: DirectoryProperty @TaskAction fun reverseFiles() { // tag::worker-daemon[] // Create a WorkQueue with process isolation val workQueue = workerExecutor.processIsolation() { // Configure the options for the forked process forkOptions { maxHeapSize = "512m"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/noIsolation/groovy/build.gradle
this.workerExecutor = workerExecutor } @TaskAction void reverseFiles() { // Create a WorkQueue to submit work items WorkQueue workQueue = workerExecutor.noIsolation() // Create and submit a unit of work for each file source.each { file -> workQueue.submit(ReverseFile.class) { ReverseParameters parameters -> parameters.fileToReverse = file
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/plugins/buildServiceFromWorkAction/kotlin/buildSrc/src/main/java/Download.java
@ServiceReference("web") abstract Property<WebServer> getServer(); @TaskAction public void download() { WorkQueue workQueue = getWorkerExecutor().noIsolation(); workQueue.submit(DownloadWorkAction.class, parameter -> { parameter.getServer().set(getServer()); }); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/waitForCompletion/kotlin/build.gradle.kts
@TaskAction fun reverseFiles() { // tag::wait-for-completion[] // Create a WorkQueue to submit work items val workQueue = workerExecutor.noIsolation() // Create and submit a unit of work for each file source.forEach { file -> workQueue.submit(ReverseFile::class) { fileToReverse = file destinationDir = outputDir }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/tasks/PrefixHeaderFileGenerateTask.java
this.workerExecutor = workerExecutor; } @TaskAction void generatePrefixHeaderFile() { WorkQueue workQueue = workerExecutor.noIsolation(); workQueue.submit(GeneratePrefixHeaderFile.class, new Action<PrefixHeaderFileParameters>() { @Override public void execute(@Nonnull PrefixHeaderFileParameters parameters) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
name: name, kubeClient: kubeClient, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.NewTypedMaxOfRateLimiter[string]( workqueue.NewTypedItemExponentialFailureRateLimiter[string](200*time.Millisecond, 1000*time.Second), // 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
ec := &EstablishingController{ crdClient: crdClient, crdLister: crdInformer.Lister(), crdSynced: crdInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "crdEstablishing"}, ), } ec.syncFn = ec.sync return ec }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/md5NoIsolation/groovy/buildSrc/src/main/java/CreateMD5.java
@TaskAction public void createHashes() { WorkQueue workQueue = getWorkerExecutor().noIsolation(); // <2> for (File sourceFile : getSource().getFiles()) { Provider<RegularFile> md5File = getDestinationDirectory().file(sourceFile.getName() + ".md5"); workQueue.submit(GenerateMD5.class, parameters -> { // <3> parameters.getSourceFile().set(sourceFile);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 990 bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/md5ClassloaderIsolation/groovy/buildSrc/src/main/java/CreateMD5.java
public void createHashes() { WorkQueue workQueue = getWorkerExecutor().classLoaderIsolation(workerSpec -> { workerSpec.getClasspath().from(getCodecClasspath()); // <2> }); for (File sourceFile : getSource().getFiles()) { Provider<RegularFile> md5File = getDestinationDirectory().file(sourceFile.getName() + ".md5"); workQueue.submit(GenerateMD5.class, parameters -> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.3K bytes - Viewed (0)