Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for mustNewPodInfo (0.16 sec)

  1. pkg/scheduler/framework/plugins/queuesort/priority_sort_test.go

    			p1: &framework.QueuedPodInfo{
    				PodInfo: mustNewPodInfo(t, st.MakePod().Priority(lowPriority).Obj()),
    			},
    			p2: &framework.QueuedPodInfo{
    				PodInfo: mustNewPodInfo(t, st.MakePod().Priority(highPriority).Obj()),
    			},
    			expected: false, // p2 should be ahead of p1 in the queue
    		},
    		{
    			name: "p1.priority greater than p2.priority",
    			p1: &framework.QueuedPodInfo{
    				PodInfo: mustNewPodInfo(t, st.MakePod().Priority(highPriority).Obj()),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 12 14:11:04 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	highPriorityPodInfo = mustNewPodInfo(
    		st.MakePod().Name("hpp").Namespace("ns1").UID("hppns1").Priority(highPriority).Obj(),
    	)
    	highPriNominatedPodInfo = mustNewPodInfo(
    		st.MakePod().Name("hpp").Namespace("ns1").UID("hppns1").Priority(highPriority).NominatedNodeName("node1").Obj(),
    	)
    	medPriorityPodInfo = mustNewPodInfo(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    			// Add test.addedPod to state1 and verify it is equal to allPodsState.
    			nodeInfo := mustGetNodeInfo(t, snapshot, test.addedPod.Spec.NodeName)
    			if err := ipa.AddPod(ctx, cycleState, test.pendingPod, mustNewPodInfo(t, test.addedPod), nodeInfo); err != nil {
    				t.Errorf("error adding pod to meta: %v", err)
    			}
    
    			newState, err := getPreFilterState(cycleState)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  4. pkg/scheduler/scheduler_test.go

    			}
    
    			s, fwk, err := initScheduler(ctx, schedulerCache, queue, client, informerFactory)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			testPodInfo := &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(t, testPod)}
    			s.FailureHandler(ctx, fwk, testPodInfo, framework.NewStatus(framework.Unschedulable), nil, time.Now())
    
    			var got *v1.Pod
    			if tt.podUpdatedDuringScheduling {
    				head, e := queue.Pop(logger)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    				t.Fatal(err)
    			}
    
    			sched := &Scheduler{
    				Cache:  cache,
    				client: client,
    				NextPod: func(logger klog.Logger) (*framework.QueuedPodInfo, error) {
    					return &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(t, item.sendPod)}, nil
    				},
    				SchedulingQueue: internalqueue.NewTestQueue(ctx, nil),
    				Profiles:        profile.Map{testSchedulerName: fwk},
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/runtime/framework_test.go

    				)
    			}
    
    			podNominator := internalqueue.NewPodNominator(nil)
    			if tt.nominatedPod != nil {
    				podNominator.AddNominatedPod(
    					logger,
    					mustNewPodInfo(t, tt.nominatedPod),
    					&framework.NominatingInfo{NominatingMode: framework.ModeOverride, NominatedNodeName: nodeName})
    			}
    			profile := config.KubeSchedulerProfile{Plugins: cfgPls}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    				t.Fatal(s.AsError())
    			}
    			nodeInfo, err := snapshot.Get(tt.nodes[tt.nodeIdx].Name)
    			if err != nil {
    				t.Fatal(err)
    			}
    			if s := p.AddPod(ctx, cs, tt.preemptor, mustNewPodInfo(t, tt.addedPod), nodeInfo); !s.IsSuccess() {
    				t.Fatal(s.AsError())
    			}
    			state, err := getPreFilterState(cs)
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
Back to top