Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 25 of 25 for UniversalDecoder (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/config.go

    	if err != nil {
    		return nil, fmt.Errorf("unable to read admission control configuration from %q [%v]", configFilePath, err)
    	}
    	codecs := serializer.NewCodecFactory(configScheme)
    	decoder := codecs.UniversalDecoder()
    	decodedObj, err := runtime.Decode(decoder, data)
    	// we were able to decode the file successfully
    	if err == nil {
    		decodedConfig, ok := decodedObj.(*apiserver.AdmissionConfiguration)
    		if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/config/joinconfiguration.go

    		return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind)
    	}
    
    	internalcfg := &kubeadmapi.JoinConfiguration{}
    	if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), joinBytes, internalcfg); err != nil {
    		return nil, err
    	}
    
    	// Applies dynamic defaults to settings not provided with flags
    	if err := SetJoinDynamicDefaults(internalcfg, skipCRIDetect); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/config/resetconfiguration.go

    		return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind)
    	}
    
    	internalcfg := &kubeadmapi.ResetConfiguration{}
    	if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), resetBytes, internalcfg); err != nil {
    		return nil, err
    	}
    
    	// Applies dynamic defaults to settings not provided with flags
    	if err := SetResetDynamicDefaults(internalcfg, skipCRIDetect); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/addons/proxy/proxy_test.go

    		t.Run(testCase.name, func(t *testing.T) {
    			daemonSetBytes, _ := kubeadmutil.ParseTemplate(testCase.manifest, testCase.data)
    			daemonSet := &apps.DaemonSet{}
    			if err := runtime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), daemonSetBytes, daemonSet); err != nil {
    				t.Errorf("unexpected error: %v", err)
    			}
    			if daemonSet.Spec.Template.Spec.PriorityClassName != "system-node-critical" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 11:14:32 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/util/config/upgradeconfiguration.go

    			// right external version, defaulted, and converted into the internal version.
    			if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), bytes, internalcfg); err != nil {
    				return nil, err
    			}
    			continue
    		}
    
    		// If the group is neither a kubeadm core type or of a supported component config group, we dump a warning about it being ignored
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 7.8K bytes
    - Viewed (0)
Back to top