- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for mustNewPodInfo (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)