Skip to content

Commit b6aad25

Browse files
authored
Merge pull request kubernetes-sigs#2624 from chuckha/version
🏃 Be consistent with versioning in KubeadmControlPlane
2 parents 2369761 + 639ae47 commit b6aad25

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

controlplane/kubeadm/controllers/kubeadm_control_plane_controller.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -369,7 +369,7 @@ func (r *KubeadmControlPlaneReconciler) upgradeControlPlane(ctx context.Context,
369369
return ctrl.Result{}, errors.Wrap(err, "failed to reconcile the remote kubelet RBAC binding")
370370
}
371371

372-
if err := workloadCluster.UpdateKubernetesVersionInKubeadmConfigMap(ctx, kcp.Spec.Version); err != nil {
372+
if err := workloadCluster.UpdateKubernetesVersionInKubeadmConfigMap(ctx, parsedVersion); err != nil {
373373
return ctrl.Result{}, errors.Wrap(err, "failed to update the kubernetes version in the kubeadm config map")
374374
}
375375

controlplane/kubeadm/internal/workload_cluster.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ type WorkloadCluster interface {
6767
// Behaviors necessary for upgrade
6868
ReconcileKubeletRBACBinding(ctx context.Context, version semver.Version) error
6969
ReconcileKubeletRBACRole(ctx context.Context, version semver.Version) error
70-
UpdateKubernetesVersionInKubeadmConfigMap(ctx context.Context, version string) error
70+
UpdateKubernetesVersionInKubeadmConfigMap(ctx context.Context, version semver.Version) error
7171
UpdateEtcdVersionInKubeadmConfigMap(ctx context.Context, imageRepository, imageTag string) error
7272
UpdateKubeletConfigMap(ctx context.Context, version semver.Version) error
7373
UpdateKubeProxyImageInfo(ctx context.Context, kcp *controlplanev1.KubeadmControlPlane) error
@@ -286,14 +286,14 @@ func (w *Workload) UpdateEtcdVersionInKubeadmConfigMap(ctx context.Context, imag
286286
}
287287

288288
// UpdateKubernetesVersionInKubeadmConfigMap updates the kubernetes version in the kubeadm config map.
289-
func (w *Workload) UpdateKubernetesVersionInKubeadmConfigMap(ctx context.Context, version string) error {
289+
func (w *Workload) UpdateKubernetesVersionInKubeadmConfigMap(ctx context.Context, version semver.Version) error {
290290
configMapKey := ctrlclient.ObjectKey{Name: "kubeadm-config", Namespace: metav1.NamespaceSystem}
291291
kubeadmConfigMap, err := w.getConfigMap(ctx, configMapKey)
292292
if err != nil {
293293
return err
294294
}
295295
config := &kubeadmConfig{ConfigMap: kubeadmConfigMap}
296-
if err := config.UpdateKubernetesVersion(version); err != nil {
296+
if err := config.UpdateKubernetesVersion(fmt.Sprintf("v%s", version)); err != nil {
297297
return err
298298
}
299299
if err := w.Client.Update(ctx, config.ConfigMap); err != nil {

0 commit comments

Comments
 (0)