Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for enableNodeInclusionPolicyInPodTopologySpread (0.93 sec)

  1. pkg/scheduler/framework/plugins/feature/feature.go

    // the internal k8s features pkg.
    type Features struct {
    	EnableDynamicResourceAllocation              bool
    	EnableVolumeCapacityPriority                 bool
    	EnableNodeInclusionPolicyInPodTopologySpread bool
    	EnableMatchLabelKeysInPodTopologySpread      bool
    	EnablePodDisruptionConditions                bool
    	EnableInPlacePodVerticalScaling              bool
    	EnableSidecarContainers                      bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    		return
    	}
    	if !nodeLabelsMatchSpreadConstraints(node.Labels, s.Constraints) {
    		return
    	}
    
    	requiredSchedulingTerm := nodeaffinity.GetRequiredNodeAffinity(preemptorPod)
    	if !pl.enableNodeInclusionPolicyInPodTopologySpread {
    		// spreading is applied to nodes that pass those filters.
    		// Ignore parsing errors for backwards compatibility.
    		if match, _ := requiredSchedulingTerm.Match(node); !match {
    			return
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    	}
    	pl := &PodTopologySpread{
    		parallelizer:       h.Parallelizer(),
    		sharedLister:       h.SnapshotSharedLister(),
    		defaultConstraints: args.DefaultConstraints,
    		enableNodeInclusionPolicyInPodTopologySpread: fts.EnableNodeInclusionPolicyInPodTopologySpread,
    		enableMatchLabelKeysInPodTopologySpread:      fts.EnableMatchLabelKeysInPodTopologySpread,
    	}
    	if args.DefaultingType == config.SystemDefaulting {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/podtopologyspread/common.go

    				NodeTaintsPolicy:   v1.NodeInclusionPolicyIgnore, // If NodeTaintsPolicy is nil, we treat NodeTaintsPolicy as "Ignore".
    			}
    			if pl.enableNodeInclusionPolicyInPodTopologySpread {
    				if c.NodeAffinityPolicy != nil {
    					tsc.NodeAffinityPolicy = *c.NodeAffinityPolicy
    				}
    				if c.NodeTaintsPolicy != nil {
    					tsc.NodeTaintsPolicy = *c.NodeTaintsPolicy
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/registry.go

    		EnableVolumeCapacityPriority:                 feature.DefaultFeatureGate.Enabled(features.VolumeCapacityPriority),
    		EnableNodeInclusionPolicyInPodTopologySpread: feature.DefaultFeatureGate.Enabled(features.NodeInclusionPolicyInPodTopologySpread),
    		EnableMatchLabelKeysInPodTopologySpread:      feature.DefaultFeatureGate.Enabled(features.MatchLabelKeysInPodTopologySpread),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/podtopologyspread/scoring.go

    	requiredNodeAffinity := nodeaffinity.GetRequiredNodeAffinity(pod)
    	processAllNode := func(i int) {
    		nodeInfo := allNodes[i]
    		node := nodeInfo.Node()
    
    		if !pl.enableNodeInclusionPolicyInPodTopologySpread {
    			// `node` should satisfy incoming pod's NodeSelector/NodeAffinity
    			if match, _ := requiredNodeAffinity.Match(node); !match {
    				return
    			}
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    			}
    
    			p := plugintesting.SetupPluginWithInformers(ctx, t, topologySpreadFunc, args, cache.NewSnapshot(tt.existingPods, tt.nodes), tt.objs)
    			p.(*PodTopologySpread).enableNodeInclusionPolicyInPodTopologySpread = tt.enableNodeInclusionPolicy
    			p.(*PodTopologySpread).enableMatchLabelKeysInPodTopologySpread = tt.enableMatchLabelKeys
    
    			cs := framework.NewCycleState()
    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/podtopologyspread/scoring_test.go

    				frameworkruntime.WithInformerFactory(informerFactory))
    			if err != nil {
    				t.Fatalf("Failed creating framework runtime: %v", err)
    			}
    			pl, err := New(ctx, &tt.config, f, feature.Features{EnableNodeInclusionPolicyInPodTopologySpread: tt.enableNodeInclusionPolicy})
    			if err != nil {
    				t.Fatalf("Failed creating plugin: %v", err)
    			}
    			informerFactory.Start(ctx.Done())
    			informerFactory.WaitForCacheSync(ctx.Done())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 60K bytes
    - Viewed (0)
Back to top