Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for preFilterState (0.19 sec)

  1. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    )
    
    // preFilterState computed at PreFilter and used at Filter.
    type preFilterState struct {
    	// Names of the pod's volumes using the ReadWriteOncePod access mode.
    	readWriteOncePodPVCs sets.Set[string]
    	// The number of references to these ReadWriteOncePod volumes by scheduled pods.
    	conflictingPVCRefCount int
    }
    
    func (s *preFilterState) updateWithPod(podInfo *framework.PodInfo, multiplier int) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    	return nil
    }
    
    func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) {
    	c, err := cycleState.Read(preFilterStateKey)
    	if err != nil {
    		// preFilterState doesn't exist, likely PreFilter wasn't invoked.
    		return nil, fmt.Errorf("error reading %q from cycleState: %w", preFilterStateKey, err)
    	}
    
    	s, ok := c.(*preFilterState)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    }
    
    // getPreFilterState fetches a pre-computed preFilterState.
    func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) {
    	c, err := cycleState.Read(preFilterStateKey)
    	if err != nil {
    		// preFilterState doesn't exist, likely PreFilter wasn't invoked.
    		return nil, fmt.Errorf("reading %q from cycleState: %w", preFilterStateKey, err)
    	}
    
    	s, ok := c.(*preFilterState)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    	}
    	cycleState.Write(preFilterStateKey, preFilterState(s))
    	return nil, nil
    }
    
    // PreFilterExtensions do not exist for this plugin.
    func (pl *NodePorts) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getPreFilterState(cycleState *framework.CycleState) (preFilterState, error) {
    	c, err := cycleState.Read(preFilterStateKey)
    	if err != nil {
    		// preFilterState doesn't exist, likely PreFilter wasn't invoked.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go

    func (pl *NodeAffinity) Name() string {
    	return Name
    }
    
    type preFilterState struct {
    	requiredNodeSelectorAndAffinity nodeaffinity.RequiredNodeAffinity
    }
    
    // Clone just returns the same state because it is not affected by pod additions or deletions.
    func (s *preFilterState) Clone() framework.StateData {
    	return s
    }
    
    // EventsToRegister returns the possible events that may make a Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/fit.go

    }
    
    // ScoreExtensions of the Score plugin.
    func (f *Fit) ScoreExtensions() framework.ScoreExtensions {
    	return nil
    }
    
    // preFilterState computed at PreFilter and used at Filter.
    type preFilterState struct {
    	framework.Resource
    }
    
    // Clone the prefilter state.
    func (s *preFilterState) Clone() framework.StateData {
    	return s
    }
    
    // preScoreState computed at PreScore and used at Score.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    		nodes                     []*v1.Node
    		existingPods              []*v1.Pod
    		objs                      []runtime.Object
    		defaultConstraints        []v1.TopologySpreadConstraint
    		want                      *preFilterState
    		wantPrefilterStatus       *framework.Status
    		enableNodeInclusionPolicy bool
    		enableMatchLabelKeys      bool
    	}{
    		{
    			name: "clean cluster with one spreadConstraint",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    		existingPods         []*v1.Pod
    		nodes                []*v1.Node
    		expectedAntiAffinity topologyToMatchedTermCount
    		expectedAffinity     topologyToMatchedTermCount
    	}{
    		{
    			name: "preFilterState anti-affinity terms are updated correctly after adding and removing a pod",
    			pendingPod: &v1.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: "pending", Labels: selector1},
    				Spec: v1.PodSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
Back to top