Skip to content

Commit

Permalink
ran gofumpt
Browse files Browse the repository at this point in the history
  • Loading branch information
deepakm-ntnx committed Feb 2, 2024
1 parent a7d7daa commit 42c1d16
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 9 deletions.
8 changes: 3 additions & 5 deletions test/e2e/cluster_topology.go
Original file line number Diff line number Diff line change
Expand Up @@ -121,8 +121,7 @@ func (e2eTest *NutanixE2ETest) CreateCluster(ctx context.Context, clusterTopolog
WorkerMachineCount: pointer.Int64Ptr(int64(clusterTopologyConfig.workerNodeCount)),
}

var clusterResources *clusterctl.ApplyClusterTemplateAndWaitResult
clusterResources = new(clusterctl.ApplyClusterTemplateAndWaitResult)
clusterResources := new(clusterctl.ApplyClusterTemplateAndWaitResult)

clusterctl.ApplyClusterTemplateAndWait(ctx, clusterctl.ApplyClusterTemplateAndWaitInput{
ClusterProxy: e2eTest.bootstrapClusterProxy,
Expand All @@ -149,8 +148,7 @@ func (e2eTest *NutanixE2ETest) UpgradeCluster(ctx context.Context, clusterTopolo
WorkerMachineCount: pointer.Int64Ptr(int64(clusterTopologyConfig.workerNodeCount)),
}

var clusterResources *clusterctl.ApplyClusterTemplateAndWaitResult
clusterResources = new(clusterctl.ApplyClusterTemplateAndWaitResult)
clusterResources := new(clusterctl.ApplyClusterTemplateAndWaitResult)

clusterctl.ApplyClusterTemplateAndWait(ctx, clusterctl.ApplyClusterTemplateAndWaitInput{
ClusterProxy: e2eTest.bootstrapClusterProxy,
Expand All @@ -169,7 +167,7 @@ func (e2eTest *NutanixE2ETest) WaitForControlPlaneMachinesToBeUpgraded(ctx conte
framework.WaitForControlPlaneMachinesToBeUpgraded(ctx, framework.WaitForControlPlaneMachinesToBeUpgradedInput{
Lister: mgmtClient,
Cluster: clusterResources.Cluster,
MachineCount: int(*&clusterTopologyConfig.cpNodeCount),
MachineCount: int(clusterTopologyConfig.cpNodeCount),
KubernetesUpgradeVersion: clusterTopologyConfig.k8sVersion,
}, waitForMachinesToBeUpgraded...)
}
Expand Down
3 changes: 1 addition & 2 deletions test/e2e/cluster_topology_basic_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ var _ = Describe("When creating a cluster with topology with simple workflow", L
)
})

var basicWorkflow = func(targetKubeVer, targetImageName string) {
basicWorkflow := func(targetKubeVer, targetImageName string) {
By("Creating a workload cluster with topology")
clusterTopologyConfig := NewClusterTopologyConfig(
WithName(clusterName),
Expand Down Expand Up @@ -91,7 +91,6 @@ var _ = Describe("When creating a cluster with topology with simple workflow", L
kube127 := testHelper.getVariableFromE2eConfig("KUBERNETES_VERSION_v1_27")
kube127Image := testHelper.getVariableFromE2eConfig("NUTANIX_MACHINE_TEMPLATE_IMAGE_NAME_v1_27")
basicWorkflow(kube127, kube127Image)

})

It("Create a cluster with topology with version Kube128", func() {
Expand Down
3 changes: 1 addition & 2 deletions test/e2e/cluster_topology_conformance_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ var _ = Describe("When creating a cluster with topology and running kubetest/con
)
})

var conformanceWorkflow = func(targetKubeVer, targetImageName string) {
conformanceWorkflow := func(targetKubeVer, targetImageName string) {
By("Creating a workload cluster with topology")
clusterTopologyConfig := NewClusterTopologyConfig(
WithName(clusterName),
Expand Down Expand Up @@ -100,7 +100,6 @@ var _ = Describe("When creating a cluster with topology and running kubetest/con
kube127 := testHelper.getVariableFromE2eConfig("KUBERNETES_VERSION_v1_27")
kube127Image := testHelper.getVariableFromE2eConfig("NUTANIX_MACHINE_TEMPLATE_IMAGE_NAME_v1_27")
conformanceWorkflow(kube127, kube127Image)

})

It("Create a cluster with topology with version Kube128", func() {
Expand Down

0 comments on commit 42c1d16

Please sign in to comment.