- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for RunFilterPluginsWithNominatedPods (0.82 sec)
-
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
// support this case for performance reasons. Having affinity to lower // priority pods is not a recommended configuration anyway. if status := pl.fh.RunFilterPluginsWithNominatedPods(ctx, state, pod, nodeInfo); !status.IsSuccess() { return nil, 0, status } var victims []*v1.Pod numViolatingVictim := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// EventRecorder returns an event recorder. EventRecorder() events.EventRecorder SharedInformerFactory() informers.SharedInformerFactory // RunFilterPluginsWithNominatedPods runs the set of configured filter plugins for nominated pod on the given node. RunFilterPluginsWithNominatedPods(ctx context.Context, state *CycleState, pod *v1.Pod, info *NodeInfo) *Status // Extenders returns registered scheduler extenders. Extenders() []Extender
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/framework/runtime/framework.go
f.metricsRecorder.ObservePluginDurationAsync(metrics.PostFilter, pl.Name(), s.Code().String(), metrics.SinceInSeconds(startTime)) return r, s } // RunFilterPluginsWithNominatedPods runs the set of configured filter plugins // for nominated pod on the given node. // This function is called from two different places: Schedule and Preempt.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
// this is to make sure all nodes have the same chance of being examined across pods. nodeInfo := nodes[(sched.nextStartNodeIndex+i)%numAllNodes] status := fwk.RunFilterPluginsWithNominatedPods(ctx, state, pod, nodeInfo) if status.Code() == framework.Error { errCh.SendErrorWithCancel(status.AsError(), cancel) return } if status.IsSuccess() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
if err != nil { t.Fatalf("fail to create framework: %s", err) } tt.nodeInfo.SetNode(tt.node) gotStatus := f.RunFilterPluginsWithNominatedPods(ctx, framework.NewCycleState(), tt.pod, tt.nodeInfo) if diff := cmp.Diff(gotStatus, tt.wantStatus, cmpOpts...); diff != "" { t.Errorf("Unexpected status: (-got, +want):\n%s", diff) } }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0)