- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for LabelSelectorAsSelector (0.4 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)