mirror of
				https://github.com/k3s-io/kubernetes.git
				synced 2025-11-03 23:40:03 +00:00 
			
		
		
		
	@@ -28,7 +28,6 @@ go_library(
 | 
			
		||||
        "//staging/src/k8s.io/api/rbac/v1:go_default_library",
 | 
			
		||||
        "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library",
 | 
			
		||||
        "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
 | 
			
		||||
        "//staging/src/k8s.io/apimachinery/pkg/types:go_default_library",
 | 
			
		||||
        "//staging/src/k8s.io/client-go/kubernetes:go_default_library",
 | 
			
		||||
        "//vendor/github.com/golang/glog:go_default_library",
 | 
			
		||||
        "//vendor/k8s.io/utils/exec:go_default_library",
 | 
			
		||||
 
 | 
			
		||||
@@ -21,7 +21,6 @@ import (
 | 
			
		||||
 | 
			
		||||
	"k8s.io/api/core/v1"
 | 
			
		||||
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 | 
			
		||||
	"k8s.io/apimachinery/pkg/types"
 | 
			
		||||
	clientset "k8s.io/client-go/kubernetes"
 | 
			
		||||
	kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
 | 
			
		||||
	"k8s.io/kubernetes/cmd/kubeadm/app/util/apiclient"
 | 
			
		||||
@@ -38,23 +37,22 @@ func EnableDynamicConfigForNode(client clientset.Interface, nodeName string, kub
 | 
			
		||||
		nodeName, configMapName, metav1.NamespaceSystem)
 | 
			
		||||
	fmt.Println("[kubelet] WARNING: The Dynamic Kubelet Config feature is beta, but off by default. It hasn't been well-tested yet at this stage, use with caution.")
 | 
			
		||||
 | 
			
		||||
	kubeletConfigMap, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(configMapName, metav1.GetOptions{})
 | 
			
		||||
	_, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(configMapName, metav1.GetOptions{})
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		return fmt.Errorf("couldn't get the kubelet configuration ConfigMap: %v", err)
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	// Loop on every falsy return. Return with an error if raised. Exit successfully if true is returned.
 | 
			
		||||
	return apiclient.PatchNode(client, nodeName, func(n *v1.Node) {
 | 
			
		||||
		patchNodeForDynamicConfig(n, configMapName, kubeletConfigMap.UID)
 | 
			
		||||
		patchNodeForDynamicConfig(n, configMapName)
 | 
			
		||||
	})
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func patchNodeForDynamicConfig(n *v1.Node, configMapName string, configMapUID types.UID) {
 | 
			
		||||
func patchNodeForDynamicConfig(n *v1.Node, configMapName string) {
 | 
			
		||||
	n.Spec.ConfigSource = &v1.NodeConfigSource{
 | 
			
		||||
		ConfigMap: &v1.ConfigMapNodeConfigSource{
 | 
			
		||||
			Name:             configMapName,
 | 
			
		||||
			Namespace:        metav1.NamespaceSystem,
 | 
			
		||||
			UID:              configMapUID,
 | 
			
		||||
			KubeletConfigKey: kubeadmconstants.KubeletBaseConfigurationConfigMapKey,
 | 
			
		||||
		},
 | 
			
		||||
	}
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user