Skip to content

Commit 75643a8

Browse files
committed
fixup! refactor: Address review feedback
1 parent c3876bd commit 75643a8

File tree

2 files changed

+8
-5
lines changed
  • common/pkg/testutils/capitest
  • pkg/handlers/generic/mutation/externalcloudprovider

2 files changed

+8
-5
lines changed

common/pkg/testutils/capitest/patches.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ func AssertGeneratePatches[T mutation.GeneratePatches](
6666
if tt.ExpectedFailure {
6767
g.Expect(resp.Status).
6868
To(gomega.Equal(runtimehooksv1.ResponseStatusFailure), fmt.Sprintf("Message: %s", resp.Message))
69+
g.Expect(resp.Items).To(gomega.BeEmpty())
6970
return
7071
}
7172

pkg/handlers/generic/mutation/externalcloudprovider/inject.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import (
2222
)
2323

2424
var (
25-
versionGreatOrEqualTo133Range = semver.MustParseRange(">=1.33.0-0")
25+
versionGreaterOrEqualTo133Range = semver.MustParseRange(">=1.33.0-0")
2626
)
2727

2828
type externalCloudProviderPatchHandler struct{}
@@ -61,7 +61,7 @@ func (h *externalCloudProviderPatchHandler) Mutate(
6161
return fmt.Errorf("failed to get control plane Kubernetes version from builtin variable: %w", err)
6262
}
6363

64-
cpK8sVersion, err := semver.ParseTolerant(cpVersion)
64+
kubernetesVersion, err := semver.ParseTolerant(cpVersion)
6565
if err != nil {
6666
log.WithValues(
6767
"kubernetesVersion",
@@ -70,9 +70,9 @@ func (h *externalCloudProviderPatchHandler) Mutate(
7070
return fmt.Errorf("failed to parse control plane Kubernetes version: %w", err)
7171
}
7272

73-
if versionGreatOrEqualTo133Range(cpK8sVersion) {
73+
if versionGreaterOrEqualTo133Range(kubernetesVersion) {
7474
log.V(5).Info(
75-
"skipping external cloud-provider flag to control plane kubeadm config template because Kubernetes < 1.33.0",
75+
"skipping external cloud-provider flag to control plane kubeadm config template because Kubernetes >= 1.33.0",
7676
)
7777
return nil
7878
}
@@ -86,7 +86,9 @@ func (h *externalCloudProviderPatchHandler) Mutate(
8686
if obj.Spec.Template.Spec.KubeadmConfigSpec.ClusterConfiguration.APIServer.ExtraArgs == nil {
8787
obj.Spec.Template.Spec.KubeadmConfigSpec.ClusterConfiguration.APIServer.ExtraArgs = make(map[string]string, 1)
8888
}
89-
obj.Spec.Template.Spec.KubeadmConfigSpec.ClusterConfiguration.APIServer.ExtraArgs["cloud-provider"] = "external"
89+
if _, ok := obj.Spec.Template.Spec.KubeadmConfigSpec.ClusterConfiguration.APIServer.ExtraArgs["cloud-provider"]; !ok {
90+
obj.Spec.Template.Spec.KubeadmConfigSpec.ClusterConfiguration.APIServer.ExtraArgs["cloud-provider"] = "external"
91+
}
9092

9193
return nil
9294
}); err != nil {

0 commit comments

Comments
 (0)