- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 55 for UniversalDecoder (0.24 sec)
-
pkg/apis/autoscaling/v2beta2/defaults_test.go
data, err := runtime.Encode(legacyscheme.Codecs.LegacyCodec(SchemeGroupVersion), obj) if err != nil { t.Errorf("%v\n %#v", err, obj) return nil } obj2, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), data) if err != nil { t.Errorf("%v\nData: %s\nSource: %#v", err, string(data), obj) return nil } obj3 := reflect.New(reflect.TypeOf(obj).Elem()).Interface().(runtime.Object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 11.6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/proxy/proxy_test.go
t.Run(testCase.name, func(t *testing.T) { daemonSetBytes, _ := kubeadmutil.ParseTemplate(testCase.manifest, testCase.data) daemonSet := &apps.DaemonSet{} if err := runtime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), daemonSetBytes, daemonSet); err != nil { t.Errorf("unexpected error: %v", err) } if daemonSet.Spec.Template.Spec.PriorityClassName != "system-node-critical" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/apis/autoscaling/v2/defaults_test.go
data, err := runtime.Encode(legacyscheme.Codecs.LegacyCodec(SchemeGroupVersion), obj) if err != nil { t.Errorf("%v\n %#v", err, obj) return nil } obj2, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), data) if err != nil { t.Errorf("%v\nData: %s\nSource: %#v", err, string(data), obj) return nil } obj3 := reflect.New(reflect.TypeOf(obj).Elem()).Interface().(runtime.Object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 11.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/upgradeconfiguration.go
// right external version, defaulted, and converted into the internal version. if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), bytes, internalcfg); err != nil { return nil, err } continue } // If the group is neither a kubeadm core type or of a supported component config group, we dump a warning about it being ignored
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
klog.Warning(err.Error()) } // As long as we support only component configs with a single kind, this is allowed return runtime.DecodeInto(Codecs.UniversalDecoder(), yaml, into) } return nil } // ensureInitializedComponentConfigs is an utility func to initialize the ComponentConfigMap in ClusterConfiguration prior to possible writes to it
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/objectmeta/coerce_test.go
} // double check this what the kube JSON decode is doing bs, _ := utiljson.Marshal(u.UnstructuredContent()) kubeObj, _, err := clientgoscheme.Codecs.UniversalDecoder(corev1.SchemeGroupVersion).Decode(bs, nil, nil) if err != nil { t.Fatal(err) } pod, ok := kubeObj.(*corev1.Pod) if !ok { t.Fatalf("expected v1 Pod, got: %T", pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 12.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster.go
kubeadmapiv1.SchemeGroupVersion.WithKind(constants.ClusterConfigurationKind), []byte(clusterConfigurationData)); err != nil { klog.Warning(err.Error()) } if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), []byte(clusterConfigurationData), &initcfg.ClusterConfiguration); err != nil { return nil, errors.Wrap(err, "failed to decode cluster configuration data") } if !skipComponentConfigs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K bytes - Viewed (0) -
pkg/apis/apps/v1beta1/defaults_test.go
data, err := runtime.Encode(legacyscheme.Codecs.LegacyCodec(SchemeGroupVersion), obj) if err != nil { t.Errorf("%v\n %#v", err, obj) return nil } obj2, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), data) if err != nil { t.Errorf("%v\nData: %s\nSource: %#v", err, string(data), obj) return nil } obj3 := reflect.New(reflect.TypeOf(obj).Elem()).Interface().(runtime.Object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
var decoded *apidiscoveryv2beta1.APIGroupDiscoveryList if len(bytes) > 0 { decoded = &apidiscoveryv2beta1.APIGroupDiscoveryList{} err := runtime.DecodeInto(codecs.UniversalDecoder(), bytes, decoded) if err != nil { panic(fmt.Sprintf("failed to decode response: %v", err)) } } return r, bytes, decoded }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
if err != nil { responseError = "unable to read error from server response" } else { // TODO: I don't belong here, I should be abstracted from this class if obj, _, err := statusCodecs.UniversalDecoder().Decode(responseErrorBytes, nil, &metav1.Status{}); err == nil { if status, ok := obj.(*metav1.Status); ok { return nil, &apierrors.StatusError{ErrStatus: *status} } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0)