- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for enqueuePdb (0.24 sec)
-
pkg/controller/garbagecollector/garbagecollector_test.go
pendingAttemptToDelete: []*node{ makeNode(badSecretReferenceWithDeploymentUID, virtual), // virtual parent enqueued for delete attempt makeNode(goodChildPod, withOwners(deployment1apps)), // good child enqueued for delete attempt }, }), // 7,8: process pending delete of virtual parent processAttemptToDelete(1), assertState(state{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
{ PluginName: "fooPlugin1", QueueingHintFn: queueHintReturnQueue, }, }, }, }, }, { name: "Pod, registered in inFlightPods, is enqueued back to activeQ", isSchedulingQueueHintEnabled: true, initialPods: []*v1.Pod{pod, pod2}, actions: []action{ // This won't be added to inFlightEvents because no inFlightPods at this point.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
manager.enqueueDaemonSet = func(ds *apps.DaemonSet) { if ds.Name == "ds" { enqueued = true } } enqueued = false manager.updateNode(logger, c.oldNode, c.newNode) if enqueued != c.shouldEnqueue { t.Errorf("Test case: '%s', expected: %t, got: %t", c.test, c.shouldEnqueue, enqueued) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
t.Errorf("Found taint %v in %v, which should not be present", NotReadyTaintTemplate, node3.Spec.Taints) } } // TestApplyNoExecuteTaintsToNodesEnqueueTwice ensures we taint every node with NoExecute even if enqueued twice func TestApplyNoExecuteTaintsToNodesEnqueueTwice(t *testing.T) { // TODO: Remove skip once https://github.com/kubernetes/kubernetes/pull/114607 merges. if goruntime.GOOS == "windows" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
val response = client.newCall(request).execute() assertThat(response.body.string()).isEqualTo("B") } @Test fun requestOnlyIfCachedWithNoResponseCached() { // (no responses enqueued) val request = Request.Builder() .url(server.url("/")) .header("Cache-Control", "only-if-cached") .build() val response = client.newCall(request).execute()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 108.6K bytes - Viewed (0)