Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for RunFilterPluginsWithNominatedPods (0.82 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top