Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 39 for MakeNode (0.14 sec)

  1. pkg/scheduler/framework/plugins/noderesources/test_util.go

    	extendedResourceSet = []config.ResourceSpec{
    		{Name: string(v1.ResourceCPU), Weight: 1},
    		{Name: string(v1.ResourceMemory), Weight: 1},
    		{Name: extendedRes, Weight: 1},
    	}
    )
    
    func makeNode(node string, milliCPU, memory int64, extendedResource map[string]int64) *v1.Node {
    	resourceList := make(map[v1.ResourceName]resource.Quantity)
    	for res, quantity := range extendedResource {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 01:07:28 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one_test.go

    	return nil
    }
    
    func TestSchedulerMultipleProfilesScheduling(t *testing.T) {
    	nodes := []runtime.Object{
    		st.MakeNode().Name("node1").UID("node1").Obj(),
    		st.MakeNode().Name("node2").UID("node2").Obj(),
    		st.MakeNode().Name("node3").UID("node3").Obj(),
    	}
    	pods := []*v1.Pod{
    		st.MakePod().Name("pod1").UID("pod1").SchedulerName("match-node3").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/workload_prep.go

    	var labelPairs []keyVal
    	for k, v := range labels {
    		labelPairs = append(labelPairs, keyVal{k: k, v: v})
    	}
    	zones := 10
    	// build nodes
    	for i := 0; i < allNodesNum; i++ {
    		node := MakeNode().Name(fmt.Sprintf("node%d", i)).
    			Label(v1.LabelTopologyZone, fmt.Sprintf("zone%d", i%zones)).
    			Label(v1.LabelHostname, fmt.Sprintf("node%d", i)).Obj()
    		allNodes = append(allNodes, node)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 16 13:43:36 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/dump_test.go

    				{F: types.UID("foxtrot"), T: types.UID("golf")},
    			},
    		},
    		{
    			file: "escaping.dot",
    			nodes: []*dotVertex{
    				NewDOTVertex(makeNode(ref1, withOwners(ref2))),
    				NewDOTVertex(makeNode(ref2)),
    			},
    			edges: []dotEdge{
    				{F: types.UID(ref1.UID), T: types.UID(ref2.UID)},
    			},
    		},
    	}
    
    	for _, tc := range testcases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/volumebinding/test_utils.go

    	"k8s.io/apimachinery/pkg/api/resource"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/component-helpers/storage/volume"
    	"k8s.io/utils/ptr"
    )
    
    type nodeBuilder struct {
    	*v1.Node
    }
    
    func makeNode(name string) nodeBuilder {
    	return nodeBuilder{Node: &v1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    			Labels: map[string]string{
    				v1.LabelHostname: name,
    			},
    		},
    	}}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/cache_test.go

    			nodes: []*v1.Node{
    				&st.MakeNode().Name("test-node-1").Capacity(resourceList1).Taints(taints).Images(imageStatus1).Node,
    				&st.MakeNode().Name("test-node-2").Capacity(resourceList2).Taints(taints).Images(imageStatus2).Node,
    				&st.MakeNode().Name("test-node-3").Capacity(resourceList1).Taints(taints).Images(imageStatus1).Node,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  7. pkg/scheduler/scheduler_test.go

    		testSchedulerProfile2 = "test-scheduler-profile-2"
    		testSchedulerProfile3 = "test-scheduler-profile-3"
    	)
    
    	nodes := []runtime.Object{
    		st.MakeNode().Name("node1").UID("node1").Obj(),
    		st.MakeNode().Name("node2").UID("node2").Obj(),
    		st.MakeNode().Name("node3").UID("node3").Obj(),
    	}
    
    	cases := []struct {
    		name                        string
    		profiles                    []schedulerapi.KubeSchedulerProfile
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    	topoMismatchClass        = "topoMismatchClass"
    
    	// nodes objects
    	node1         = makeNode("node1").withLabel(nodeLabelKey, "node1").Node
    	node2         = makeNode("node2").withLabel(nodeLabelKey, "node2").Node
    	node1NoLabels = makeNode("node1").Node
    	node1Zone1    = makeNode("node1").withLabel("topology.gke.io/zone", "us-east-1").Node
    	node1Zone2    = makeNode("node1").withLabel("topology.gke.io/zone", "us-east-2").Node
    
    	// csiNode objects
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/queue/scheduling_queue_test.go

    				PodInfo:              mustNewPodInfo(st.MakePod().Name("pod1").Namespace("ns1").UID("1").Obj()),
    			},
    			event:                  NodeAdd,
    			oldObj:                 nil,
    			newObj:                 st.MakeNode().Obj(),
    			expected:               queueSkip,
    			expectedExecutionCount: 0,
    			queueingHintMap: QueueingHintMapPerProfile{
    				"": {
    					// no queueing hint function for NodeAdd.
    					AssignedPodAdd: {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  10. pkg/scheduler/testing/wrappers.go

    func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper {
    	p.Spec.Overhead = rl
    	return p
    }
    
    // NodeWrapper wraps a Node inside.
    type NodeWrapper struct{ v1.Node }
    
    // MakeNode creates a Node wrapper.
    func MakeNode() *NodeWrapper {
    	w := &NodeWrapper{v1.Node{}}
    	return w.Capacity(nil)
    }
    
    // Obj returns the inner Node.
    func (n *NodeWrapper) Obj() *v1.Node {
    	return &n.Node
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 42.1K bytes
    - Viewed (0)
Back to top