Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 186 for TopologyKey (0.29 sec)

  1. manifests/charts/gateways/istio-ingress/templates/_affinity.tpl

              values:
              {{- $vals := split "," $item.values }}
              {{- range $i, $v := $vals }}
              - {{ $v | quote }}
              {{- end }}
              {{- end }}
          topologyKey: {{ $item.topologyKey }}
          {{- if $item.namespaces }}
          namespaces:
          {{- $ns := split "," $item.namespaces }}
          {{- range $i, $n := $ns }}
          - {{ $n | quote }}
          {{- end }}
          {{- end }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Aug 10 21:23:08 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  2. manifests/charts/gateways/istio-egress/templates/_affinity.tpl

              values:
              {{- $vals := split "," $item.values }}
              {{- range $i, $v := $vals }}
              - {{ $v | quote }}
              {{- end }}
              {{- end }}
          topologyKey: {{ $item.topologyKey }}
          {{- if $item.namespaces }}
          namespaces:
          {{- $ns := split "," $item.namespaces }}
          {{- range $i, $n := $ns }}
          - {{ $n | quote }}
          {{- end }}
          {{- end }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Aug 10 21:23:08 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    			wantFilterStatuses:  []*framework.Status{nil, nil},
    			name:                "Test existing pod's anti-affinity: if an existing pod has a term with invalid topologyKey, labelSelector of the term is firstly checked, and then topologyKey of the term is also checked",
    		},
    		{
    			pod: st.MakePod().Node("nodeA").Namespace(defaultNamespace).PodAntiAffinityExists("foo", "invalid-node-label", st.PodAntiAffinityWithRequiredReq).Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  9. 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)
  10. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    	if len(state.existingAntiAffinityCounts) > 0 {
    		// Iterate over topology pairs to get any of the pods being affected by
    		// the scheduled pod anti-affinity terms
    		for topologyKey, topologyValue := range nodeInfo.Node().Labels {
    			tp := topologyPair{key: topologyKey, value: topologyValue}
    			if state.existingAntiAffinityCounts[tp] > 0 {
    				return false
    			}
    		}
    	}
    	return true
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
Back to top