Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 55 for UniversalDecoder (0.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. staging/src/k8s.io/cli-runtime/pkg/printers/json_test.go

    	err = unmarshalFunc(buf.Bytes(), &poutput)
    	if err != nil {
    		t.Fatal(err)
    	}
    	// Use real decode function to undo the versioning process.
    	poutput = TestStruct{}
    	s := scheme.Codecs.UniversalDecoder(scheme.Scheme.PrioritizedVersionsAllGroups()...)
    	if err := runtime.DecodeInto(s, buf.Bytes(), &poutput); err != nil {
    		t.Fatal(err)
    	}
    	if !reflect.DeepEqual(testData, poutput) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 4K bytes
    - Viewed (0)
  10. pkg/credentialprovider/plugin/config.go

    	}
    
    	return config, nil
    }
    
    // decode decodes data into the internal CredentialProviderConfig type.
    func decode(data []byte) (*kubeletconfig.CredentialProviderConfig, error) {
    	obj, gvk, err := codecs.UniversalDecoder().Decode(data, nil, nil)
    	if err != nil {
    		return nil, err
    	}
    
    	if gvk.Kind != "CredentialProviderConfig" {
    		return nil, fmt.Errorf("failed to decode %q (wrong Kind)", gvk.Kind)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 19 15:11:57 UTC 2023
    - 4.5K bytes
    - Viewed (0)
Back to top