- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for workqueue (0.19 sec)
-
pkg/kubelet/util/queue/work_queue_test.go
tests := []struct { clock clock.Clock expectedWorkQueue WorkQueue }{ { clock: clock.RealClock{}, expectedWorkQueue: &basicWorkQueue{queue: make(map[types.UID]time.Time), clock: clock.RealClock{}}, }, } for _, test := range tests { workQueue := NewBasicWorkQueue(test.clock) assert.Equal(t, test.expectedWorkQueue, workQueue) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.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/endpointslice/endpointslice_controller.go
// overwhelm the API Server. serviceQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.NewTypedMaxOfRateLimiter( workqueue.NewTypedItemExponentialFailureRateLimiter[string](defaultSyncBackOff, maxSyncBackOff), // 10 qps, 100 bucket size. This is only for retry speed and its // only the overall factor (not per item).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
), pvcListerSynced: pvcInformer.Informer().HasSynced, revListerSynced: revInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "statefulset"}, ), podControl: controller.RealPodControl{KubeClient: kubeClient, Recorder: recorder},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
manifests/addons/dashboards/lib/output.json
"legendFormat": "{{cluster}} - {{namespace}}\n" } ], "title": "Workqueue Waiting Duration Over Time", "type": "heatmap" }, { "datasource": { "type": "datasource", "uid": "-- Mixed --"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
podInformer.Informer().GetStore().Add(pod) } // Overwrite queue fakeClock := testingclock.NewFakeClock(time.Now()) gcc.nodeQueue.ShutDown() gcc.nodeQueue = workqueue.NewTypedDelayingQueueWithConfig(workqueue.TypedDelayingQueueConfig[string]{Clock: fakeClock, Name: "podgc_test_queue"}) // First GC of orphaned pods gcc.gc(ctx) deletedPodNames := getDeletedPodNames(client)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
finalizerExpectations: newUIDTrackingExpectations(), queue: workqueue.NewTypedRateLimitingQueueWithConfig(workqueue.NewTypedItemExponentialFailureRateLimiter[string](DefaultJobApiBackOff, MaxJobApiBackOff), workqueue.TypedRateLimitingQueueConfig[string]{Name: "job", Clock: clock}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} // verify all are enqueued if e, a := sets.New[string]("1-normal", "2-static", "4-static", "3-static"), podWorkers.workQueue.(*fakeQueue).Set(); !e.Equal(a) { t.Fatalf("unexpected queued items: %s", cmp.Diff(e, a)) } // send a basic update for 3-static podWorkers.workQueue.GetWork() podWorkers.UpdatePod(UpdatePodOptions{ Pod: newNamedPod("3-static", "test1", "pod1", true),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
pods[2].Status.StartTime = &startTime pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds kubelet.podManager.SetPods(pods) kubelet.workQueue.Enqueue(pods[2].UID, 0) kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second) kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute) clock.Step(1 * time.Minute) expected := []*v1.Pod{pods[2], pods[3], pods[0]} podsToSync := kubelet.getPodsToSync()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} klet.containerLogManager = containerLogManager klet.reasonCache = NewReasonCache() klet.workQueue = queue.NewBasicWorkQueue(klet.clock) klet.podWorkers = newPodWorkers( klet, kubeDeps.Recorder, klet.workQueue, klet.resyncInterval, backOffPeriod, klet.podCache, ) runtime, err := kuberuntime.NewKubeGenericRuntimeManager(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (1)