Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for preFilterState (0.22 sec)

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