Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for PreFilterExtensions (0.54 sec)

  1. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go

    			return nil, nil
    		}
    	}
    
    	return nil, framework.NewStatus(framework.Skip)
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *nonCSILimits) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    // Filter invoked at the filter extension point.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  2. cmd/kube-scheduler/app/server_test.go

    	return &foo{}, nil
    }
    
    func (*foo) PreFilter(_ context.Context, _ *framework.CycleState, _ *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	return nil, nil
    }
    
    func (*foo) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func (*foo) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/fit.go

    	}
    	cycleState.Write(preFilterStateKey, computePodResourceRequest(pod))
    	return nil, nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (f *Fit) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) {
    	c, err := cycleState.Read(preFilterStateKey)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/framework.go

    	if !state.ShouldRecordPluginMetrics() {
    		return pl.PreFilterExtensions().AddPod(ctx, state, podToSchedule, podInfoToAdd, nodeInfo)
    	}
    	startTime := time.Now()
    	status := pl.PreFilterExtensions().AddPod(ctx, state, podToSchedule, podInfoToAdd, nodeInfo)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/runtime/framework_test.go

    	return pl.inj.PreFilterResult, framework.NewStatus(framework.Code(pl.inj.PreFilterStatus), injectReason)
    }
    
    func (pl *TestPlugin) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    func (pl *TestPlugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	}
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *dynamicResources) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getStateData(cs *framework.CycleState) (*stateData, error) {
    	state, err := cs.Read(stateKey)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    	}
    	return nil
    }
    
    func (pl *TestPlugin) Name() string {
    	return pl.name
    }
    
    func (pl *TestPlugin) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    func (pl *TestPlugin) PreFilter(ctx context.Context, state *framework.CycleState, p *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	return nil, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
Back to top