- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for UniversalDecoder (0.28 sec)
-
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) -
pkg/apis/networking/v1beta1/defaults_test.go
t.Helper() 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: Tue Mar 03 19:11:16 UTC 2020 - 3.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/uploadconfig/uploadconfig_test.go
if configData == "" { t2.Fatal("Fail to find ClusterConfigurationConfigMapKey key") } decodedCfg := &kubeadmapi.ClusterConfiguration{} if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), []byte(configData), decodedCfg); err != nil { t2.Fatalf("unable to decode config from bytes: %v", err) } if len(decodedCfg.ComponentConfigs) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 08:46:51 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/apis/batch/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: Sun Jan 08 12:14:37 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/clientset_generated.go
// for a real clientset and is mostly useful in simple unit tests. func NewSimpleClientset(objects ...runtime.Object) *Clientset { o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) for _, obj := range objects { if err := o.Add(obj); err != nil { panic(err) } } cs := &Clientset{tracker: o} cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 09 06:03:32 UTC 2021 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go
// for a real clientset and is mostly useful in simple unit tests. func NewSimpleClientset(objects ...runtime.Object) *Clientset { o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) for _, obj := range objects { if err := o.Add(obj); err != nil { panic(err) } } cs := &Clientset{tracker: o} cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/apis/autoscaling/v1/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 - 4.7K bytes - Viewed (0) -
pkg/apis/autoscaling/v2beta1/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 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/log/backend_test.go
backend := NewBackend(&buf, FormatJson, version) backend.ProcessEvents(event) // decode events back and compare with the original one. result := &auditinternal.Event{} decoder := audit.Codecs.UniversalDecoder(version) if err := runtime.DecodeInto(decoder, buf.Bytes(), result); err != nil { t.Errorf("failed decoding buf: %s, apiVersion: %s", buf.String(), version) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 08 06:37:26 UTC 2022 - 5K bytes - Viewed (0)