Read Kubelet configuration the same way as Kubelet to apply default v…

…alues

Signed-off-by: PiotrProkop <[email protected]>

pkg/utils/kubeconf/kubelet_config_file.go

@@ -17,23 +17,40 @@ limitations under the License.
 package kubeconf
 
 import (
-	"os"
-
-	"github.com/ghodss/yaml"
+	"fmt"
 
 	kubeletconfigv1beta1 "k8s.io/kubelet/config/v1beta1"
+	kubeletconfigscheme "k8s.io/kubernetes/pkg/kubelet/apis/config/scheme"
+	"k8s.io/kubernetes/pkg/kubelet/kubeletconfig/configfiles"
+	utilfs "k8s.io/kubernetes/pkg/util/filesystem"
 )
 
 // GetKubeletConfigFromLocalFile returns KubeletConfiguration loaded from the node local config
+// based on https://github.com/kubernetes/kubernetes/blob/master/cmd/kubelet/app/server.go#L337
+// it fills empty fields with default values
 func GetKubeletConfigFromLocalFile(kubeletConfigPath string) (*kubeletconfigv1beta1.KubeletConfiguration, error) {
-	kubeletBytes, err := os.ReadFile(kubeletConfigPath)
+	const errFmt = "failed to load Kubelet config file %s, error %v"
+
+	loader, err := configfiles.NewFsLoader(&utilfs.DefaultFs{}, kubeletConfigPath)
+	if err != nil {
+		return nil, fmt.Errorf(errFmt, kubeletConfigPath, err)
+	}
+
+	kc, err := loader.Load()
+	if err != nil {
+		return nil, fmt.Errorf(errFmt, kubeletConfigPath, err)
+	}
+
+	scheme, _, err := kubeletconfigscheme.NewSchemeAndCodecs()
 	if err != nil {
 		return nil, err
 	}
 
 	kubeletConfig := &kubeletconfigv1beta1.KubeletConfiguration{}
-	if err := yaml.Unmarshal(kubeletBytes, kubeletConfig); err != nil {
+	err = scheme.Convert(kc, kubeletConfig, nil)
+	if err != nil {
 		return nil, err
 	}
+
 	return kubeletConfig, nil
 }