Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for makeNodes (0.2 sec)

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

    			requestedPod: st.MakePod().
    				Req(map[v1.ResourceName]string{"cpu": "3000", "memory": "5000"}).
    				Obj(),
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node1").Capacity(map[v1.ResourceName]string{"cpu": "4000", "memory": "10000"}).Obj(),
    				st.MakeNode().Name("node2").Capacity(map[v1.ResourceName]string{"cpu": "6000", "memory": "10000"}).Obj(),
    			},
    			existingPods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/preemption/preemption_test.go

    		initPods           []*v1.Pod
    		numViolatingVictim int
    		expected           [][]Candidate
    	}{
    		{
    			name: "no pdb violation",
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node1").Capacity(veryLargeRes).Obj(),
    				st.MakeNode().Name("node2").Capacity(veryLargeRes).Obj(),
    			},
    			testPods: []*v1.Pod{
    				st.MakePod().Name("p").UID("p").Priority(highPriority).Obj(),
    			},
    			initPods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				st.MakePod().Name("p2").UID("p2").Namespace(v1.NamespaceDefault).Node("node2").Obj(),
    			},
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node1").Capacity(nodeRes).Obj(),
    				st.MakeNode().Name("node2").Capacity(nodeRes).Obj(),
    				st.MakeNode().Name("node3").Capacity(nodeRes).Obj(),
    				st.MakeNode().Name("node4").Capacity(nodeRes).Obj(),
    			},
    			filteredNodesStatuses: framework.NodeToStatusMap{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pkg/apis/core/validation/validation_test.go

    	}{{
    		expectError: false,
    		node:        makeNode("nil-pod-cidr", nil),
    	}, {
    		expectError: false,
    		node:        makeNode("empty-pod-cidr", []string{}),
    	}, {
    		expectError: false,
    		node:        makeNode("single-pod-cidr-4", []string{"192.168.0.0/16"}),
    	}, {
    		expectError: false,
    		node:        makeNode("single-pod-cidr-6", []string{"2000::/10"}),
    	},
    
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    				PodResourceClaims(v1.PodResourceClaim{Name: resourceName2, Source: v1.ClaimSource{ResourceClaimName: &claimName2}}).
    				Obj()
    
    	workerNode      = &st.MakeNode().Name("worker").Label("kubernetes.io/hostname", "worker").Node
    	workerNodeSlice = st.MakeResourceSlice("worker", "some-driver").NamedResourcesInstances("instance-1").Obj()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
Back to top