Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for NodeNames (0.21 sec)

  1. pkg/scheduler/framework/interface_test.go

    			want:     &PreFilterResult{NodeNames: sets.New[string]()},
    		},
    		"nil receiver populated input": {
    			in:   &PreFilterResult{NodeNames: sets.New("node1")},
    			want: &PreFilterResult{NodeNames: sets.New("node1")},
    		},
    		"empty receiver populated input": {
    			receiver: &PreFilterResult{NodeNames: sets.New[string]()},
    			in:       &PreFilterResult{NodeNames: sets.New("node1")},
    			want:     &PreFilterResult{NodeNames: sets.New[string]()},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Oct 22 04:41:59 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go

    			return nil, nil
    		}
    		nodeNames = nodeNames.Union(termNodeNames)
    	}
    	// If nodeNames is not nil, but length is 0, it means each term have conflicting affinity to node.Name;
    	// therefore, pod will not match any node.
    	if nodeNames != nil && len(nodeNames) == 0 {
    		return nil, framework.NewStatus(framework.UnschedulableAndUnresolvable, errReasonConflict)
    	} else if len(nodeNames) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  3. pkg/scheduler/extender.go

    			nodeNameSlice = append(nodeNameSlice, node.Node().Name)
    		}
    		nodeNames = &nodeNameSlice
    	} else {
    		nodeList = &v1.NodeList{}
    		for _, node := range nodes {
    			nodeList.Items = append(nodeList.Items, *node.Node())
    		}
    	}
    
    	args = &extenderv1.ExtenderArgs{
    		Pod:       pod,
    		Nodes:     nodeList,
    		NodeNames: nodeNames,
    	}
    
    	if err := h.send(h.filterVerb, args, &result); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/upgrade/plan.go

    			nodeNames := up.Before.KubeletVersions[oldVersion]
    			for _, nodeName := range nodeNames {
    				components = append(components, newComponentUpgradePlan(constants.Kubelet, oldVersion, up.After.KubeVersion, nodeName))
    			}
    		}
    	}
    
    	for _, oldVersion := range sortedSliceFromStringStringArrayMap(up.Before.KubeAPIServerVersions) {
    		nodeNames := up.Before.KubeAPIServerVersions[oldVersion]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 03:03:29 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    	labelKeys := []string{"hostname", "zone", "region"}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			nodes := make([]*v1.Node, len(tt.nodeNames))
    			fakeFilterRCMap := make(map[string]framework.Code, len(tt.nodeNames))
    			for i, nodeName := range tt.nodeNames {
    				nodeWrapper := st.MakeNode().Capacity(veryLargeRes)
    				// Split node name by '/' to form labels in a format of
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/preemption/preemption_test.go

    			}
    		})
    	}
    }
    
    func TestSelectCandidate(t *testing.T) {
    	tests := []struct {
    		name      string
    		nodeNames []string
    		pod       *v1.Pod
    		testPods  []*v1.Pod
    		expected  string
    	}{
    		{
    			name:      "pod has different number of containers on each node",
    			nodeNames: []string{"node1", "node2", "node3"},
    			pod:       st.MakePod().Name("p").UID("p").Priority(highPriority).Req(veryLargeRes).Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/interface.go

    		r.NodeNames = p.NodeNames.Clone()
    		return &r
    	}
    
    	r.NodeNames = p.NodeNames.Intersection(in.NodeNames)
    	return &r
    }
    
    type NominatingMode int
    
    const (
    	ModeNoop NominatingMode = iota
    	ModeOverride
    )
    
    type NominatingInfo struct {
    	NominatedNodeName string
    	NominatingMode    NominatingMode
    }
    
    // PostFilterResult wraps needed info for scheduler framework to act upon PostFilter phase.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  8. pkg/scheduler/extender_test.go

    				},
    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			// nodeInfos instantiations
    			nodeInfoList := make([]*framework.NodeInfo, 0, len(tt.nodeNames))
    			for i, nm := range tt.nodeNames {
    				nodeInfo := framework.NewNodeInfo()
    				node := createNode(nm)
    				nodeInfo.SetNode(node)
    				nodeInfo.AddPod(tt.podsInNodeList[i])
    				nodeInfo.AddPod(tt.podsInNodeList[i+2])
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go

    			}
    			volumeNames = append(volumeNames, v)
    			podNames = append(podNames, p)
    			nodeNames = append(nodeNames, n)
    		}
    
    		t.Run(fmt.Sprintf("Test %d", test.testID), func(t *testing.T) {
    			if test.expectPass {
    				testConcurrentOperationsPositive(t,
    					volumeNames[0], podNames[0], nodeNames[0],
    					volumeNames[1], podNames[1], nodeNames[1],
    				)
    			} else {
    				testConcurrentOperationsNegative(t,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 36.1K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    											},
    										},
    									},
    								},
    							},
    						},
    					},
    				},
    			},
    			nodeName:            "node1",
    			wantPreFilterResult: &framework.PreFilterResult{NodeNames: sets.New("node1")},
    			runPreFilter:        true,
    		},
    		{
    			name: "Pod with matchFields using In operator that does not match the existing node",
    			pod: &v1.Pod{
    				Spec: v1.PodSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
Back to top