Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 59 for UniversalDecoder (0.48 sec)

  1. 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)
  2. 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)
  3. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/codec_factory.go

    //
    // This method is deprecated - clients and servers should negotiate a serializer by mime-type and
    // invoke CodecForVersions. Callers that need only to read data should use UniversalDecoder().
    //
    // TODO: make this call exist only in pkg/api, and initialize it with the set of default versions.
    // All other callers will be forced to request a Codec directly.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top