|
9 | 9 |
|
10 | 10 | argoCDV1Aplha1 "github.com/argoproj/argo-cd/v2/pkg/apis/application/v1alpha1" |
11 | 11 | yqCmdLib "github.com/mikefarah/yq/v4/cmd" |
| 12 | + clusterctlClientLib "sigs.k8s.io/cluster-api/cmd/clusterctl/client" |
12 | 13 | "sigs.k8s.io/controller-runtime/pkg/client" |
13 | 14 |
|
14 | 15 | "github.com/Obmondo/kubeaid-bootstrap-script/pkg/config" |
@@ -218,10 +219,17 @@ func upgradeControlPlane( |
218 | 219 | ) |
219 | 220 |
|
220 | 221 | // Rollout the control-plane, immediately |
221 | | - utils.ExecuteCommandOrDie(fmt.Sprintf( |
222 | | - "clusterctl alpha rollout restart kubeadmcontrolplane/%s -n %s", |
223 | | - kubeadmControlPlaneName, kubernetes.GetCapiClusterNamespace(), |
224 | | - )) |
| 222 | + |
| 223 | + clusterctlClient, err := clusterctlClientLib.New(ctx, "") |
| 224 | + assert.AssertErrNil(ctx, err, "Failed constructing clusterctl client") |
| 225 | + |
| 226 | + err = clusterctlClient.RolloutRestart(ctx, clusterctlClientLib.RolloutRestartOptions{ |
| 227 | + Namespace: kubernetes.GetCapiClusterNamespace(), |
| 228 | + Resources: []string{ |
| 229 | + fmt.Sprintf("kubeadmcontrolplane/%s", kubeadmControlPlaneName), |
| 230 | + }, |
| 231 | + }) |
| 232 | + assert.AssertErrNil(ctx, err, "Failed rolling out KubeadmControlPlane") |
225 | 233 | } |
226 | 234 | } |
227 | 235 |
|
@@ -282,9 +290,18 @@ func upgradeNodeGroup(ctx context.Context, |
282 | 290 | ) |
283 | 291 |
|
284 | 292 | // Rollout the node-group, immediately. |
285 | | - utils.ExecuteCommandOrDie(fmt.Sprintf( |
286 | | - "clusterctl alpha rollout restart machinedeployment/%s -n %s", |
287 | | - machineDeploymentName, kubernetes.GetCapiClusterNamespace(), |
288 | | - )) |
| 293 | + |
| 294 | + clusterctlClient, err := clusterctlClientLib.New(ctx, "") |
| 295 | + assert.AssertErrNil(ctx, err, "Failed constructing clusterctl client") |
| 296 | + |
| 297 | + err = clusterctlClient.RolloutRestart(ctx, clusterctlClientLib.RolloutRestartOptions{ |
| 298 | + Namespace: kubernetes.GetCapiClusterNamespace(), |
| 299 | + Resources: []string{ |
| 300 | + fmt.Sprintf("machinedeployment/%s", machineDeploymentName), |
| 301 | + }, |
| 302 | + }) |
| 303 | + assert.AssertErrNil(ctx, err, "Failed rolling out MachineDeployment", |
| 304 | + slog.String("name", machineDeploymentName), |
| 305 | + ) |
289 | 306 | } |
290 | 307 | } |
0 commit comments