Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for newNode (0.21 sec)

  1. pkg/controller/daemon/daemon_controller_test.go

    	cases := []struct {
    		name           string
    		newNode        *v1.Node
    		oldNode        *v1.Node
    		expectedResult bool
    	}{
    		{
    			name:           "Nothing changed",
    			oldNode:        newNode("node1", nil),
    			newNode:        newNode("node1", nil),
    			expectedResult: true,
    		},
    		{
    			name:           "Node labels changed",
    			oldNode:        newNode("node1", nil),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_node_status_test.go

    			newNode:         newNode(false),
    			createError:     alreadyExists,
    			existingNode:    newNode(true),
    			expectedResult:  true,
    			expectedActions: 3,
    			testSavedNode:   true,
    			savedNodeIndex:  2,
    			savedNodeCMAD:   false,
    		},
    		{
    			name:            "success case - existing node - CMAD enabled",
    			newNode:         newNode(true),
    			createError:     alreadyExists,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  3. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    				}
    			},
    			nodeIterations: []nodeIteration{
    				{
    					timeToPass: 0,
    					newNodes:   makeNodes(v1.ConditionTrue, timeNow, timeNow),
    				},
    				{
    					timeToPass: 1 * time.Minute,
    					newNodes:   makeNodes(v1.ConditionTrue, timeNow, timeNow),
    				},
    				{
    					timeToPass: 1 * time.Minute,
    					newNodes:   makeNodes(v1.ConditionFalse, timePlusTwoMinutes, timePlusTwoMinutes),
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  4. pkg/api/pod/util_test.go

    					}
    
    					DropDisabledPodFields(newPod, newPod)
    					require.Equal(t, &test.pod, newPod, "unchanged pod should never be mutated")
    
    					DropDisabledPodFields(newPod, nil)
    
    					if enabled && fieldsEnabled {
    						assert.Equal(t, &test.pod, newPod, "pod should not be mutated when both feature gates are enabled")
    						return
    					}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  5. pkg/kubelet/eviction/helpers_test.go

    func TestOrderedByPriorityProcess(t *testing.T) {
    	pod1 := newPod("low-priority-high-usage", lowPriority, nil, nil)
    	pod2 := newPod("low-priority-low-usage", lowPriority, nil, nil)
    	pod3 := newPod("high-priority-high-usage", highPriority, nil, nil)
    	pod4 := newPod("high-priority-low-usage", highPriority, nil, nil)
    	stats := map[*v1.Pod]statsapi.PodStats{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		// This function returns three values;
    		// - oldPod/newPod: each test will call Update() with these oldPod and newPod.
    		prepareFunc func(t *testing.T, logger klog.Logger, q *PriorityQueue) (oldPod, newPod *v1.Pod)
    		// schedulingHintsEnablement shows which value of QHint feature gate we test a test case with.
    		schedulingHintsEnablement []bool
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller_test.go

    	for i := 0; i < count; i++ {
    		newPod := newPod(fmt.Sprintf("pod-%v", rand.String(10)), job)
    		newPod.Status = v1.PodStatus{Phase: status}
    		newPod.Status.ContainerStatuses = []v1.ContainerStatus{
    			{
    				State: v1.ContainerState{
    					Terminated: &v1.ContainerStateTerminated{
    						FinishedAt: testFinishedAt,
    					},
    				},
    			},
    		}
    		newPod.Finalizers = append(newPod.Finalizers, batch.JobTrackingFinalizer)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	newPod, ok := obj.(*example.Pod)
    	if !ok {
    		t.Fatalf("unexpected object: %#v", obj)
    	}
    
    	// update the object should not fail precondition
    	newPod.Spec.NodeName = "machine2"
    	res, _, err := registry.Update(ctx, podName, rest.DefaultUpdatedObjectInfo(newPod), rest.ValidateAllObjectFunc, rest.ValidateAllObjectUpdateFunc, false, &metav1.UpdateOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  9. tensorflow/c/c_api.cc

      // executing the following code.
      for (int i = first_new_node_id; i < parent->graph.num_node_ids(); ++i) {
        Node* new_node = parent->graph.FindNodeId(i);
        if (new_node == nullptr) continue;
        parent->name_map[new_node->name()] = new_node;
      }
    
      // Populate 'outputs'.
      DCHECK_LE(loop_outputs.size(), num_loop_vars);
      for (int i = 0; i < loop_outputs.size(); ++i) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Apr 15 03:35:10 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_test.go

    	spec := v1.PodSpec{NodeName: string(kl.nodeName), Containers: []v1.Container{{Ports: []v1.ContainerPort{{HostPort: 80}}}}}
    	pods := []*v1.Pod{
    		podWithUIDNameNsSpec("123456789", "newpod", "foo", spec),
    		podWithUIDNameNsSpec("987654321", "oldpod", "foo", spec),
    	}
    	// Make sure the Pods are in the reverse order of creation time.
    	pods[1].CreationTimestamp = metav1.NewTime(time.Now())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top