Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 173 for TopologyKey (0.21 sec)

  1. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    	if term.Matches(pod, nsLabels) {
    		if tpValue, tpValueExist := node.Labels[term.TopologyKey]; tpValueExist {
    			if m[term.TopologyKey] == nil {
    				m[term.TopologyKey] = make(map[string]int64)
    			}
    			m[term.TopologyKey][tpValue] += int64(weight * multiplier)
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/scoring.go

    			continue
    		}
    		for i, constraint := range s.Constraints {
    			// per-node counts are calculated during Score.
    			if constraint.TopologyKey == v1.LabelHostname {
    				continue
    			}
    			pair := topologyPair{key: constraint.TopologyKey, value: node.Node().Labels[constraint.TopologyKey]}
    			if s.TopologyPairToPodCounts[pair] == nil {
    				s.TopologyPairToPodCounts[pair] = new(int64)
    				topoSize[i]++
    			}
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/client-go/applyconfigurations/core/v1/podaffinityterm.go

    }
    
    // WithTopologyKey sets the TopologyKey field in the declarative configuration to the given value
    // and returns the receiver, so that objects can be built by chaining "With" function invocations.
    // If called multiple times, the TopologyKey field is set to the value of the last call.
    func (b *PodAffinityTermApplyConfiguration) WithTopologyKey(value string) *PodAffinityTermApplyConfiguration {
    	b.TopologyKey = &value
    	return b
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 11:28:02 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    		}
    
    		if pl.enableNodeInclusionPolicyInPodTopologySpread &&
    			!constraint.matchNodeInclusionPolicies(preemptorPod, node, requiredSchedulingTerm) {
    			continue
    		}
    
    		k, v := constraint.TopologyKey, node.Labels[constraint.TopologyKey]
    		pair := topologyPair{key: k, value: v}
    		s.TpPairToMatchNum[pair] += delta
    		s.TpKeyToCriticalPaths[k].update(v, s.TpPairToMatchNum[pair])
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. pkg/scheduler/testing/wrappers.go

    func (p *PodWrapper) PodAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper {
    	labelSelector := MakeLabelSelector().Exists(labelKey).Obj()
    	p.PodAffinity(topologyKey, labelSelector, kind)
    	return p
    }
    
    // PodAntiAffinityExists creates a PodAntiAffinity with the operator "Exists"
    // and injects into the inner pod.
    func (p *PodWrapper) PodAntiAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 42.1K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/podtopologyspread/common.go

    				}
    				if len(matchLabels) > 0 {
    					selector = mergeLabelSetWithSelector(matchLabels, selector)
    				}
    			}
    
    			tsc := topologySpreadConstraint{
    				MaxSkew:            c.MaxSkew,
    				TopologyKey:        c.TopologyKey,
    				Selector:           selector,
    				MinDomains:         ptr.Deref(c.MinDomains, 1),   // If MinDomains is nil, we treat MinDomains as 1.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. pkg/scheduler/apis/config/validation/validation_pluginargs_test.go

    			args: &config.PodTopologySpreadArgs{
    				DefaultConstraints: []v1.TopologySpreadConstraint{
    					{
    						MaxSkew:           1,
    						TopologyKey:       "node",
    						WhenUnsatisfiable: v1.DoNotSchedule,
    					},
    					{
    						MaxSkew:           2,
    						TopologyKey:       "zone",
    						WhenUnsatisfiable: v1.ScheduleAnyway,
    					},
    				},
    				DefaultingType: config.ListDefaulting,
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    			pod:  st.MakePod().Name("p").Label("foo", "bar").Label("baz", "kar").Obj(),
    			defaultConstraints: []v1.TopologySpreadConstraint{
    				{MaxSkew: 3, TopologyKey: "node", WhenUnsatisfiable: v1.DoNotSchedule},
    				{MaxSkew: 2, TopologyKey: "node", WhenUnsatisfiable: v1.ScheduleAnyway},
    				{MaxSkew: 5, TopologyKey: "rack", WhenUnsatisfiable: v1.DoNotSchedule},
    			},
    			objs: []runtime.Object{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go

    			pod:          st.MakePod().Name("p").PodAffinityIn("service", "zone", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(),
    			newNode:      st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(),
    			expectedHint: framework.Queue,
    		},
    		{
    			name:         "add a new node with matched pod anti-affinity topologyKey",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go

    								{
    									Key:      "security",
    									Operator: metav1.LabelSelectorOpIn,
    									Values:   []string{"S1"},
    								},
    							},
    						},
    						TopologyKey: "region",
    					},
    				},
    			},
    		},
    	}
    	stayWithS2InRegion := &v1.Affinity{
    		PodAffinity: &v1.PodAffinity{
    			PreferredDuringSchedulingIgnoredDuringExecution: []v1.WeightedPodAffinityTerm{
    				{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 44.8K bytes
    - Viewed (0)
Back to top