Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for UniversalDecoder (0.24 sec)

  1. pkg/kubelet/kubeletconfig/util/codec/codec.go

    	var (
    		obj runtime.Object
    		gvk *schema.GroupVersionKind
    	)
    
    	// The UniversalDecoder runs defaulting and returns the internal type by default.
    	obj, gvk, err := kubeletCodecs.UniversalDecoder().Decode(data, nil, nil)
    	if err != nil {
    		// Try strict decoding first. If that fails decode with a lenient
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 21:48:29 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. cmd/kubeadm/app/phases/addons/dns/dns.go

    }
    
    func createCoreDNSAddon(deploymentBytes, serviceBytes, configBytes []byte, client clientset.Interface) error {
    	coreDNSConfigMap := &v1.ConfigMap{}
    	if err := kuberuntime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), configBytes, coreDNSConfigMap); err != nil {
    		return errors.Wrapf(err, "%s ConfigMap", unableToDecodeCoreDNS)
    	}
    
    	// Create the ConfigMap for CoreDNS or update/migrate it in case it already exists
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 10:21:20 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. plugin/pkg/admission/podtolerationrestriction/config.go

    			return nil, err
    		}
    		return internalConfig, nil
    	}
    	// we have a config so parse it.
    	data, err := ioutil.ReadAll(config)
    	if err != nil {
    		return nil, err
    	}
    	decoder := codecs.UniversalDecoder()
    	decodedObj, err := runtime.Decode(decoder, data)
    	if err != nil {
    		return nil, err
    	}
    	externalConfig, ok := decodedObj.(*internalapi.Configuration)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 08 22:33:50 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  9. plugin/pkg/admission/eventratelimit/config.go

    			return nil, err
    		}
    		return internalConfig, nil
    	}
    	// we have a config so parse it.
    	data, err := ioutil.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.(*eventratelimitapi.Configuration)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 08 22:33:50 UTC 2018
    - 2K bytes
    - Viewed (0)
  10. 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)
Back to top