- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 54 for LabelSelectorAsSelector (0.36 sec)
-
pkg/apis/rbac/validation/validation.go
allErrs = append(allErrs, unversionedvalidation.ValidateLabelSelector(&selector, labelSelectorValidationOptions, fieldPath)...) selector, err := metav1.LabelSelectorAsSelector(&selector) if err != nil { allErrs = append(allErrs, field.Invalid(fieldPath, selector, "invalid label selector.")) } } } if len(allErrs) != 0 { return allErrs } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 01:48:21 UTC 2022 - 10.4K bytes - Viewed (0) -
pkg/controller/deployment/util/deployment_util.go
// should be a superset of the deployment's selector, see https://github.com/kubernetes/kubernetes/issues/19830. namespace := deployment.Namespace selector, err := metav1.LabelSelectorAsSelector(deployment.Spec.Selector) if err != nil { return nil, err } options := metav1.ListOptions{LabelSelector: selector.String()} all, err := getRSList(namespace, options) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 07:09:11 UTC 2023 - 39.3K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage.go
} } // scaleFromStatefulSet returns a scale subresource for a statefulset. func scaleFromStatefulSet(ss *apps.StatefulSet) (*autoscaling.Scale, error) { selector, err := metav1.LabelSelectorAsSelector(ss.Spec.Selector) if err != nil { return nil, err } return &autoscaling.Scale{ // TODO: Create a variant of ObjectMeta type that only contains the fields below. ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
// selector. They will be orphaned by ClaimReplicaSets(). rsList, err := dc.rsLister.ReplicaSets(d.Namespace).List(labels.Everything()) if err != nil { return nil, err } deploymentSelector, err := metav1.LabelSelectorAsSelector(d.Spec.Selector) if err != nil { return nil, fmt.Errorf("deployment %s/%s has invalid label selector: %v", d.Namespace, d.Name, err) } // If any adoptions are attempted, we should first recheck for deletion with
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage.go
} } // scaleFromReplicaSet returns a scale subresource for a replica set. func scaleFromReplicaSet(rs *apps.ReplicaSet) (*autoscaling.Scale, error) { selector, err := metav1.LabelSelectorAsSelector(rs.Spec.Selector) if err != nil { return nil, err } return &autoscaling.Scale{ // TODO: Create a variant of ObjectMeta type that only contains the fields below. ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_dispatcher.go
// Internal error utilruntime.HandleError(err) return nil, err } case paramRef.Selector != nil: // Select everything by default if empty name and selector selector, err := metav1.LabelSelectorAsSelector(paramRef.Selector) if err != nil { // Cannot parse label selector: configuration error return nil, err } paramList, err := paramStore.List(selector) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage_test.go
t.Fatalf("error setting new statefulset (key: %s) %v: %v", key, validStatefulSet, err) } selector, err := metav1.LabelSelectorAsSelector(validStatefulSet.Spec.Selector) if err != nil { t.Fatal(err) } want := &autoscaling.Scale{ ObjectMeta: metav1.ObjectMeta{ Name: name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/matching/matching_test.go
return fc.matchResources } func (fc *fakeCriteria) GetParsedNamespaceSelector() (labels.Selector, error) { return metav1.LabelSelectorAsSelector(fc.matchResources.NamespaceSelector) } func (fc *fakeCriteria) GetParsedObjectSelector() (labels.Selector, error) { return metav1.LabelSelectorAsSelector(fc.matchResources.ObjectSelector) } func gvr(group, version, resource string) schema.GroupVersionResource {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 38.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
} } return len(notReady) == 0, notReady } func extractPodFailureReason(client kubernetes.Interface, namespace string, selector *metav1.LabelSelector) string { sel, err := metav1.LabelSelectorAsSelector(selector) if err != nil { return fmt.Sprintf("failed to get label selector: %v", err) } pods, err := getPods(client, namespace, sel) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/kube/inject/inject.go
} // If an annotation is not explicitly given, check the LabelSelectors, starting with NeverInject if useDefault { for _, neverSelector := range config.NeverInjectSelector { selector, err := metav1.LabelSelectorAsSelector(&neverSelector) if err != nil { log.Warnf("Invalid selector for NeverInjectSelector: %v (%v)", neverSelector, err) } else if !selector.Empty() && selector.Matches(labels.Set(metadata.Labels)) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (0)