Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for enqueuePdb (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top