Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for newNode (0.14 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/object-handlers.go

    	cred := getReqAccessCred(r, globalSite.Region())
    	// In a federated deployment, all the instances share config files
    	// and hence expected to have same credentials.
    	core, err := miniogo.NewCore(host, &miniogo.Options{
    		Creds:     credentials.NewStaticV4(cred.AccessKey, cred.SecretKey, ""),
    		Secure:    globalIsTLS,
    		Transport: getRemoteInstanceTransport(),
    	})
    	if err != nil {
    		return nil, err
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 124.2K bytes
    - Viewed (0)
Back to top