- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for UniversalDecoder (0.21 sec)
-
pkg/kubelet/kubeletconfig/util/codec/codec.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 21:48:29 UTC 2023 - 4.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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/scheduler/testing/framework/framework_helpers.go
"k8s.io/kubernetes/pkg/scheduler/apis/config/scheme" "k8s.io/kubernetes/pkg/scheduler/framework" "k8s.io/kubernetes/pkg/scheduler/framework/runtime" ) var configDecoder = scheme.Codecs.UniversalDecoder() // NewFramework creates a Framework from the register functions and options. func NewFramework(ctx context.Context, fns []RegisterPluginFunc, profileName string, opts ...runtime.Option) (framework.Framework, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.3K bytes - Viewed (0) -
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) -
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) -
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)