- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 97 for workqueue (0.19 sec)
-
platforms/core-execution/workers/src/main/java/org/gradle/workers/WorkerExecutor.java
public interface WorkerExecutor { /** * Creates a {@link WorkQueue} to submit work for asynchronous execution with no isolation. * * @since 5.6 */ WorkQueue noIsolation(); /** * Creates a {@link WorkQueue} to submit work for asynchronous execution with an isolated classloader. * * @since 5.6 */ WorkQueue classLoaderIsolation(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ExclusiveCacheAccessingWorker.java
import java.util.concurrent.TimeUnit; import java.util.function.Supplier; public class ExclusiveCacheAccessingWorker implements Runnable, Stoppable, AsyncCacheAccess { private final BlockingQueue<Runnable> workQueue; private final String displayName; private final ExclusiveCacheAccessCoordinator cacheAccess; private final long batchWindowMillis; private final long maximumLockingTimeMillis; private boolean closed;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 8.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/logs/container_log_manager_test.go
MaxFiles: testMaxFiles, }, osInterface: container.RealOS{}, clock: testingclock.NewFakeClock(now), mutex: sync.Mutex{}, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"}, ), maxWorkers: 10, monitoringPeriod: v1.Duration{Duration: 10 * time.Second},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0)