Make ekctl utils update-aws-node aware of Kubernetes version

It needs to pick the right manifest based on the version used.

pkg/addons/default/aws_node.go

@@ -23,7 +23,7 @@ const (
 )
 
 // UpdateAWSNode will update the `aws-node` add-on
-func UpdateAWSNode(rawClient kubernetes.RawClientInterface, region string, plan bool) (bool, error) {
+func UpdateAWSNode(rawClient kubernetes.RawClientInterface, region string, controlPlaneVersion string, plan bool) (bool, error) {
 	_, err := rawClient.ClientSet().AppsV1().DaemonSets(metav1.NamespaceSystem).Get(AWSNode, metav1.GetOptions{})
 	if err != nil {
 		if apierrs.IsNotFound(err) {
@@ -34,7 +34,11 @@ func UpdateAWSNode(rawClient kubernetes.RawClientInterface, region string, plan
 	}
 
 	// if DaemonSets is present, go through our list of assets
-	list, err := LoadAsset(AWSNode, "yaml")
+	assetName := AWSNode
+	if strings.HasPrefix(controlPlaneVersion, "1.10.") {
+		assetName += "-1.10"
+	}
+	list, err := LoadAsset(assetName, "yaml")
 	if err != nil {
 		return false, err
 	}

pkg/ctl/utils/update_aws_node.go

@@ -71,7 +71,12 @@ func doUpdateAWSNode(p *api.ProviderConfig, cfg *api.ClusterConfig, nameArg stri
 		return err
 	}
 
-	updateRequired, err := defaultaddons.UpdateAWSNode(rawClient, meta.Region, plan)
+	kubernetesVersion, err := rawClient.ServerVersion()
+	if err != nil {
+		return err
+	}
+
+	updateRequired, err := defaultaddons.UpdateAWSNode(rawClient, meta.Region, kubernetesVersion, plan)
 	if err != nil {
 		return err
 	}