Updated api bool fields with default=true to *bool. Go files

cluster/cluster.go

@@ -628,7 +628,7 @@ func parseNodeDrainInput(clusterFile string, rkeConfig *v3.RancherKubernetesEngi
 	var update bool
 	if _, ok := nodeDrainInputMap["ignore_daemonsets"]; !ok {
 		// user hasn't provided any input, default to true
-		nodeDrainInput.IgnoreDaemonSets = DefaultNodeDrainIgnoreDaemonsets
+		nodeDrainInput.IgnoreDaemonSets = &DefaultNodeDrainIgnoreDaemonsets
 		update = true
 	}
 	if _, ok := nodeDrainInputMap["timeout"]; !ok {

cluster/defaults.go

@@ -89,10 +89,10 @@ const (
 	DefaultMaxUnavailableControlplane = "1"
 	DefaultNodeDrainTimeout           = 120
 	DefaultNodeDrainGracePeriod       = -1
-	DefaultNodeDrainIgnoreDaemonsets  = true
 )
 
 var (
+	DefaultNodeDrainIgnoreDaemonsets      = true
 	DefaultDaemonSetMaxUnavailable        = intstr.FromInt(1)
 	DefaultDeploymentUpdateStrategyParams = intstr.FromString("25%")
 	DefaultDaemonSetUpdateStrategy        = v3.DaemonSetUpdateStrategy{
@@ -242,7 +242,7 @@ func (c *Cluster) setNodeUpgradeStrategy() {
 	}
 	if c.UpgradeStrategy.DrainInput == nil {
 		c.UpgradeStrategy.DrainInput = &v3.NodeDrainInput{
-			IgnoreDaemonSets: DefaultNodeDrainIgnoreDaemonsets,
+			IgnoreDaemonSets: &DefaultNodeDrainIgnoreDaemonsets,
 			// default to 120 seems to work better for controlplane nodes
 			Timeout: DefaultNodeDrainTimeout,
 			//Period of time in seconds given to each pod to terminate gracefully.

cluster/hosts.go

@@ -81,7 +81,7 @@ func (c *Cluster) InvertIndexHosts() error {
 		for k, v := range host.Labels {
 			newHost.ToAddLabels[k] = v
 		}
-		newHost.IgnoreDockerVersion = c.IgnoreDockerVersion
+		newHost.IgnoreDockerVersion = *c.IgnoreDockerVersion
 		if c.BastionHost.Address != "" {
 			// Add the bastion host information to each host object
 			newHost.BastionHost = c.BastionHost

cmd/common.go

@@ -54,9 +54,8 @@ func setOptionsFromCLI(c *cli.Context, rkeConfig *v3.RancherKubernetesEngineConf
 		rkeConfig.SSHAgentAuth = c.Bool("ssh-agent-auth")
 	}
 
-	if c.Bool("ignore-docker-version") {
-		rkeConfig.IgnoreDockerVersion = c.Bool("ignore-docker-version")
-	}
+	ignoreDockerVersion := c.Bool("ignore-docker-version")
+	rkeConfig.IgnoreDockerVersion = &ignoreDockerVersion
 
 	if c.Bool("s3") {
 		if rkeConfig.Services.Etcd.BackupConfig == nil {

cmd/up.go

@@ -317,7 +317,8 @@ func clusterUpLocal(ctx *cli.Context) error {
 		rkeConfig.Nodes = []v3.RKEConfigNode{*cluster.GetLocalRKENodeConfig()}
 	}
 
-	rkeConfig.IgnoreDockerVersion = ctx.Bool("ignore-docker-version")
+	ignoreDockerVersion := ctx.Bool("ignore-docker-version")
+	rkeConfig.IgnoreDockerVersion = &ignoreDockerVersion
 
 	// setting up the dialers
 	dialers := hosts.GetDialerOptions(nil, hosts.LocalHealthcheckFactory, nil)

services/node_util.go

@@ -52,7 +52,7 @@ func getDrainHelper(kubeClient *kubernetes.Clientset, upgradeStrategy v3.NodeUpg
 	drainHelper := drain.Helper{
 		Client:              kubeClient,
 		Force:               upgradeStrategy.DrainInput.Force,
-		IgnoreAllDaemonSets: upgradeStrategy.DrainInput.IgnoreDaemonSets,
+		IgnoreAllDaemonSets: *upgradeStrategy.DrainInput.IgnoreDaemonSets,
 		DeleteLocalData:     upgradeStrategy.DrainInput.DeleteLocalData,
 		GracePeriodSeconds:  upgradeStrategy.DrainInput.GracePeriod,
 		Timeout:             time.Second * time.Duration(upgradeStrategy.DrainInput.Timeout),