Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SupportsPreemption (0.24 sec)

  1. pkg/scheduler/framework/extender.go

    	ProcessPreemption(
    		pod *v1.Pod,
    		nodeNameToVictims map[string]*extenderv1.Victims,
    		nodeInfos NodeInfoLister,
    	) (map[string]*extenderv1.Victims, error)
    
    	// SupportsPreemption returns if the scheduler extender support preemption or not.
    	SupportsPreemption() bool
    
    	// IsIgnorable returns true indicates scheduling should not fail when this extender
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/scheduler/extender.go

    // is unavailable
    func (h *HTTPExtender) IsIgnorable() bool {
    	return h.ignorable
    }
    
    // SupportsPreemption returns true if an extender supports preemption.
    // An extender should have preempt verb defined and enabled its own node cache.
    func (h *HTTPExtender) SupportsPreemption() bool {
    	return len(h.preemptVerb) > 0
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/framework/fake_extender.go

    // IsIgnorable returns a bool value indicating whether internal errors can be ignored.
    func (f *FakeExtender) IsIgnorable() bool {
    	return f.Ignorable
    }
    
    // SupportsPreemption returns true indicating the extender supports preemption.
    func (f *FakeExtender) SupportsPreemption() bool {
    	// Assume preempt verb is always defined.
    	return true
    }
    
    // ProcessPreemption implements the extender preempt function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/preemption/preemption.go

    	victimsMap := ev.CandidatesToVictimsMap(candidates)
    	if len(victimsMap) == 0 {
    		return candidates, nil
    	}
    	for _, extender := range extenders {
    		if !extender.SupportsPreemption() || !extender.IsInterested(pod) {
    			continue
    		}
    		nodeNameToVictims, err := extender.ProcessPreemption(pod, victimsMap, nodeLister)
    		if err != nil {
    			if extender.IsIgnorable() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    func (f *fakeExtender) ProcessPreemption(
    	_ *v1.Pod,
    	_ map[string]*extenderv1.Victims,
    	_ framework.NodeInfoLister,
    ) (map[string]*extenderv1.Victims, error) {
    	return nil, nil
    }
    
    func (f *fakeExtender) SupportsPreemption() bool {
    	return false
    }
    
    func (f *fakeExtender) Filter(pod *v1.Pod, nodes []*framework.NodeInfo) ([]*framework.NodeInfo, extenderv1.FailedNodesMap, extenderv1.FailedNodesMap, error) {
    	return nil, nil, nil, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top