Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for LabelSelectorAsSelector (0.45 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/accessors.go

    		m.namespaceSelector, m.namespaceSelectorErr = metav1.LabelSelectorAsSelector(m.NamespaceSelector)
    	})
    	return m.namespaceSelector, m.namespaceSelectorErr
    }
    
    func (m *mutatingWebhookAccessor) GetParsedObjectSelector() (labels.Selector, error) {
    	m.initObjectSelector.Do(func() {
    		m.objectSelector, m.objectSelectorErr = metav1.LabelSelectorAsSelector(m.ObjectSelector)
    	})
    	return m.objectSelector, m.objectSelectorErr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers_test.go

    					Values:   []string{"qux", "norf"},
    				}},
    			},
    			expectErr: true,
    		},
    	}
    
    	for i, tc := range tc {
    		inCopy := tc.in.DeepCopy()
    		out, err := LabelSelectorAsSelector(tc.in)
    		// after calling LabelSelectorAsSelector, tc.in shouldn't be modified
    		if !reflect.DeepEqual(inCopy, tc.in) {
    			t.Errorf("[%v]expected:\n\t%#v\nbut got:\n\t%#v", i, inCopy, tc.in)
    		}
    		if err == nil && tc.expectErr {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_matcher.go

    func (m *matchCriteria) GetParsedNamespaceSelector() (labels.Selector, error) {
    	return metav1.LabelSelectorAsSelector(m.constraints.NamespaceSelector)
    }
    
    // GetParsedObjectSelector returns the converted LabelSelector which implements labels.Selector
    func (m *matchCriteria) GetParsedObjectSelector() (labels.Selector, error) {
    	return metav1.LabelSelectorAsSelector(m.constraints.ObjectSelector)
    }
    
    // GetMatchResources returns the matchConstraints
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/helper/spread.go

    			if other, err := metav1.LabelSelectorAsSelector(rs.Spec.Selector); err == nil {
    				if r, ok := other.Requirements(); ok {
    					selector = selector.Add(r...)
    				}
    			}
    		}
    	case ssKind:
    		if ss, err := ssl.StatefulSets(pod.Namespace).Get(owner.Name); err == nil {
    			if other, err := metav1.LabelSelectorAsSelector(ss.Spec.Selector); err == nil {
    				if r, ok := other.Requirements(); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 25 20:04:48 UTC 2021
    - 3.4K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_set_control_test.go

    		t.Error("Failed to set UpdatedReplicas correctly")
    	}
    	// Check all pods have correct pod index label.
    	if utilfeature.DefaultFeatureGate.Enabled(features.PodIndexLabel) {
    		selector, err := metav1.LabelSelectorAsSelector(set.Spec.Selector)
    		if err != nil {
    			t.Error(err)
    		}
    		pods, err := om.podsLister.Pods(set.Namespace).List(selector)
    		if err != nil {
    			t.Error(err)
    		}
    		if len(pods) != 3 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers.go

    	"k8s.io/apimachinery/pkg/selection"
    	"k8s.io/apimachinery/pkg/types"
    )
    
    // LabelSelectorAsSelector converts the LabelSelector api type into a struct that implements
    // labels.Selector
    // Note: This function should be kept in sync with the selector methods in pkg/labels/selector.go
    func LabelSelectorAsSelector(ps *LabelSelector) (labels.Selector, error) {
    	if ps == nil {
    		return labels.Nothing(), nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 15 10:58:36 UTC 2022
    - 9.6K bytes
    - Viewed (0)
  7. pkg/apis/apps/validation/validation.go

    	}
    
    	if spec.Selector == nil {
    		allErrs = append(allErrs, field.Required(fldPath.Child("selector"), ""))
    	} else {
    		// validate selector strictly, spec.selector was always required to pass LabelSelectorAsSelector below
    		allErrs = append(allErrs, unversionedvalidation.ValidateLabelSelector(spec.Selector, unversionedvalidation.LabelSelectorValidationOptions{AllowInvalidLabelValueInSelector: false}, fldPath.Child("selector"))...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 06 22:11:20 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  8. pkg/controller/statefulset/stateful_set_test.go

    	if err != nil {
    		t.Error(err)
    	}
    	pods, err := om.addTerminatingPod(set, 4)
    	if err != nil {
    		t.Error(err)
    	}
    	ssc.syncStatefulSet(ctx, set, pods)
    	selector, err := metav1.LabelSelectorAsSelector(set.Spec.Selector)
    	if err != nil {
    		t.Error(err)
    	}
    	pods, err = om.podsLister.Pods(set.Namespace).List(selector)
    	if err != nil {
    		t.Error(err)
    	}
    	if len(pods) != 5 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  9. pkg/kube/namespace/filter.go

    		return "", false
    	}
    	if _, ok := object.(*corev1.Namespace); ok {
    		return object.GetName(), true
    	}
    	return object.GetNamespace(), true
    }
    
    func LabelSelectorAsSelector(ps *meshapi.LabelSelector) (labels.Selector, error) {
    	if ps == nil {
    		return labels.Nothing(), nil
    	}
    	if len(ps.MatchLabels)+len(ps.MatchExpressions) == 0 {
    		return labels.Everything(), nil
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. pkg/scheduler/testing/framework/fake_listers.go

    	var selector labels.Selector
    
    	for _, rs := range f {
    		if rs.Namespace != pod.Namespace {
    			continue
    		}
    		selector, err = metav1.LabelSelectorAsSelector(rs.Spec.Selector)
    		if err != nil {
    			// This object has an invalid selector, it does not match the pod
    			continue
    		}
    
    		if selector.Matches(labels.Set(pod.Labels)) {
    			rss = append(rss, rs)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 20 10:14:08 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top