- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 142 for workqueue (0.17 sec)
-
platforms/documentation/docs/src/snippets/workerApi/md5ClassloaderIsolation/kotlin/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) -
pkg/controller/podautoscaler/rate_limiters.go
limitations under the License. */ package podautoscaler import ( "time" "k8s.io/client-go/util/workqueue" ) // FixedItemIntervalRateLimiter limits items to a fixed-rate interval type FixedItemIntervalRateLimiter struct { interval time.Duration } var _ workqueue.TypedRateLimiter[string] = &FixedItemIntervalRateLimiter{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/md5ProcessIsolation/kotlin/buildSrc/src/main/java/CreateMD5.java
abstract public DirectoryProperty getDestinationDirectory(); @Inject abstract public WorkerExecutor getWorkerExecutor(); @TaskAction public void createHashes() { // <1> WorkQueue workQueue = getWorkerExecutor().processIsolation(workerSpec -> { workerSpec.getClasspath().from(getCodecClasspath()); workerSpec.forkOptions(options -> { options.setMaxHeapSize("64m"); // <2>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/noIsolation/kotlin/build.gradle.kts
abstract val outputDir: DirectoryProperty @TaskAction fun reverseFiles() { // 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.4K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/workerApi/md5ProcessIsolation/groovy/buildSrc/src/main/java/CreateMD5.java
abstract public DirectoryProperty getDestinationDirectory(); @Inject abstract public WorkerExecutor getWorkerExecutor(); @TaskAction public void createHashes() { // <1> WorkQueue workQueue = getWorkerExecutor().processIsolation(workerSpec -> { workerSpec.getClasspath().from(getCodecClasspath()); workerSpec.forkOptions(options -> { options.setMaxHeapSize("64m"); // <2>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy
def workQueue = workerExecutor."\${isolationMode}"() items.each { name -> workQueue.submit(executionClass) { itemName = name shouldFail = error } } return workQueue }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
leaseQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "storage_version_garbage_collector_leases"}, ), storageVersionQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
// deleted is smaller than total number of other namespace scoped resources in a cluster. func nsControllerRateLimiter() workqueue.TypedRateLimiter[string] { return workqueue.NewTypedMaxOfRateLimiter( // this ensures that we retry namespace deletion at least every minute, never longer. workqueue.NewTypedItemExponentialFailureRateLimiter[string](5*time.Millisecond, 60*time.Second),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
c := &Controller{ policyInformer: policyInformer, policyQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: ControllerName}, ), policyClient: policyClient, typeChecker: typeChecker, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0)