- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for UniversalDecoder (0.39 sec)
-
pkg/kubelet/kubeletconfig/util/codec/codec.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 21:48:29 UTC 2023 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/policy/reader.go
strictDecoder := serializer.NewCodecFactory(audit.Scheme, serializer.EnableStrict).UniversalDecoder() // Try strict decoding first. _, gvk, err := strictDecoder.Decode(policyDef, nil, policy) if err != nil { if !runtime.IsStrictDecodingError(err) { return nil, fmt.Errorf("failed decoding: %w", err) } var ( lenientDecoder = audit.Codecs.UniversalDecoder(apiGroupVersions...) lenientErr error )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 04:09:40 UTC 2022 - 2.9K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/configfile.go
} return loadConfig(logger, data) } func loadConfig(logger klog.Logger, data []byte) (*config.KubeSchedulerConfiguration, error) { // The UniversalDecoder runs defaulting and returns the internal type by default. obj, gvk, err := scheme.Codecs.UniversalDecoder().Decode(data, nil, nil) if err != nil { return nil, err } if cfgObj, ok := obj.(*config.KubeSchedulerConfiguration); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 17 05:27:21 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/bench_test.go
} for _, test := range tests { b.Run(test.gvk.Kind, func(b *testing.B) { f := managedfieldstest.NewTestFieldManager(fakeTypeConverter, test.gvk) decoder := serializer.NewCodecFactory(scheme).UniversalDecoder(test.gvk.GroupVersion()) newObj, err := runtime.Decode(decoder, test.obj) if err != nil { b.Fatalf("Failed to parse yaml object: %v", err) } objMeta, err := meta.Accessor(newObj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/config.go
return nil, err } return internalConfig, nil } // we have a config so parse it. data, err := io.ReadAll(config) if err != nil { return nil, err } decoder := codecs.UniversalDecoder() decodedObj, err := runtime.Decode(decoder, data) if err != nil { return nil, err } resourceQuotaConfiguration, ok := decodedObj.(*resourcequotaapi.Configuration) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/apiserver/load/load.go
if err := scheme.Convert(externalConfig, internalConfig, nil); err != nil { return nil, err } return internalConfig, nil } decodedObj, err := runtime.Decode(codecs.UniversalDecoder(), data) if err != nil { return nil, err } configuration, ok := decodedObj.(*api.AuthorizationConfiguration) if !ok { return nil, fmt.Errorf("expected AuthorizationConfiguration, got %T", decodedObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 06:28:47 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/kubelet/config/common.go
// JSON is valid YAML, so this should work for everything. json, err := utilyaml.ToJSON(data) if err != nil { return false, nil, err } obj, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), json) if err != nil { return false, pod, err } newPod, ok := obj.(*api.Pod) // Check whether the object could be converted to single pod. if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/sparse_test.go
srcObj1 := &FakeV1Obj{ObjectMeta: metav1.ObjectMeta{Name: "foo"}} srcObj2 := &FakeV2DifferentObj{ObjectMeta: metav1.ObjectMeta{Name: "foo"}} encoder := codecs.LegacyCodec(v2, v1) decoder := codecs.UniversalDecoder(v2, v1) srcObj1Bytes, err := runtime.Encode(encoder, srcObj1) if err != nil { t.Fatal(err) } t.Log(string(srcObj1Bytes)) srcObj2Bytes, err := runtime.Encode(encoder, srcObj2) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 2.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/proxy/proxy.go
} if printManifest { return configMapBytes, nil } kubeproxyConfigMap := &v1.ConfigMap{} if err := kuberuntime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), configMapBytes, kubeproxyConfigMap); err != nil { return []byte(""), errors.Wrap(err, "unable to decode kube-proxy configmap") } if !kubeProxyCfg.IsUserSupplied() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 13:23:44 UTC 2023 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/config/kubeconfig.go
var kubeconfigFile string if configFile != nil { // we have a config so parse it. data, err := io.ReadAll(configFile) if err != nil { return "", err } decoder := codecs.UniversalDecoder() decodedObj, err := runtime.Decode(decoder, data) if err != nil { return "", err } config, ok := decodedObj.(*webhookadmission.WebhookAdmission) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 2K bytes - Viewed (0)