Skip to content

Commit 69a1780

Browse files
committed
fixup! refactor: Pass nutanix spec into CCM templating func
1 parent 384a49a commit 69a1780

File tree

4 files changed

+10
-34
lines changed

4 files changed

+10
-34
lines changed

pkg/handlers/generic/lifecycle/ccm/nutanix/handler.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ import (
1515
clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
1616
ctrlclient "sigs.k8s.io/controller-runtime/pkg/client"
1717

18+
"github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/api/v1alpha1"
1819
apivariables "github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/api/variables"
1920
"github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/pkg/handlers/generic/lifecycle/addons"
2021
"github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/pkg/handlers/generic/lifecycle/config"
@@ -125,7 +126,7 @@ func (p *provider) Apply(
125126
),
126127
p.client,
127128
helmChart,
128-
).WithValueTemplater(templateValuesFunc(clusterConfig))
129+
).WithValueTemplater(templateValuesFunc(clusterConfig.Nutanix))
129130

130131
if err = applier.Apply(ctx, cluster, p.config.DefaultsNamespace(), log); err != nil {
131132
return fmt.Errorf("failed to apply nutanix-ccm installation HelmChartProxy: %w", err)
@@ -135,7 +136,7 @@ func (p *provider) Apply(
135136
}
136137

137138
func templateValuesFunc(
138-
clusterConfig *apivariables.ClusterConfigSpec,
139+
nutanixConfig *v1alpha1.NutanixSpec,
139140
) func(*clusterv1.Cluster, string) (string, error) {
140141
return func(_ *clusterv1.Cluster, valuesTemplate string) (string, error) {
141142
helmValuesTemplate, err := template.New("").Parse(valuesTemplate)
@@ -150,15 +151,15 @@ func templateValuesFunc(
150151
PrismCentralAdditionalTrustBundle string
151152
}
152153

153-
address, port, err := clusterConfig.Nutanix.PrismCentralEndpoint.ParseURL()
154+
address, port, err := nutanixConfig.PrismCentralEndpoint.ParseURL()
154155
if err != nil {
155156
return "", err
156157
}
157158
templateInput := input{
158159
PrismCentralHost: address,
159160
PrismCentralPort: port,
160-
PrismCentralInsecure: clusterConfig.Nutanix.PrismCentralEndpoint.Insecure,
161-
PrismCentralAdditionalTrustBundle: clusterConfig.Nutanix.PrismCentralEndpoint.AdditionalTrustBundle,
161+
PrismCentralInsecure: nutanixConfig.PrismCentralEndpoint.Insecure,
162+
PrismCentralAdditionalTrustBundle: nutanixConfig.PrismCentralEndpoint.AdditionalTrustBundle,
162163
}
163164

164165
var b bytes.Buffer

pkg/handlers/generic/lifecycle/ccm/nutanix/handler_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ func Test_templateValues(t *testing.T) {
123123
tt := tests[idx]
124124
t.Run(tt.name, func(t *testing.T) {
125125
t.Parallel()
126-
out, err := templateValuesFunc(tt.clusterConfig)(nil, tt.in)
126+
out, err := templateValuesFunc(tt.clusterConfig.Nutanix)(nil, tt.in)
127127
require.NoError(t, err)
128128
assert.Equal(t, tt.expected, out)
129129
})

pkg/webhook/cluster/webhook_suite_test.go

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -93,26 +93,5 @@ func TestMain(m *testing.M) {
9393
},
9494
}},
9595
},
96-
97-
// - admissionReviewVersions:
98-
// - v1
99-
// clientConfig:
100-
// service:
101-
// name: '{{ include "chart.name" . }}-admission'
102-
// namespace: '{{ .Release.Namespace }}'
103-
// path: /mutate-v1beta1-cluster
104-
// failurePolicy: Fail
105-
// name: cluster-defaulter.caren.nutanix.com
106-
// rules:
107-
// - apiGroups:
108-
// - cluster.x-k8s.io
109-
// apiVersions:
110-
// - '*'
111-
// operations:
112-
// - CREATE
113-
// - UPDATE
114-
// resources:
115-
// - clusters
116-
// sideEffects: None
11796
}))
11897
}

test/e2e/clusterautoscaler_helpers.go

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -97,13 +97,9 @@ func WaitForClusterAutoscalerToBeReadyForWorkloadCluster(
9797
WaitForHelmReleaseProxyReadyForCluster(
9898
ctx,
9999
WaitForHelmReleaseProxyReadyForClusterInput{
100-
GetLister: input.ClusterProxy.GetClient(),
101-
Cluster: input.WorkloadCluster,
102-
HelmReleaseName: fmt.Sprintf(
103-
"%s-%s",
104-
clusterAutoscalerReleaseName,
105-
input.WorkloadCluster.Annotations[v1alpha1.ClusterUUIDAnnotationKey],
106-
),
100+
GetLister: input.ClusterProxy.GetClient(),
101+
Cluster: input.WorkloadCluster,
102+
HelmReleaseName: clusterAutoscalerReleaseName,
107103
},
108104
input.HelmReleaseIntervals...,
109105
)

0 commit comments

Comments
 (0)