- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for preFilterState (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)