- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for NodeNames (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0)