@@ -18,14 +18,14 @@ import (
1818 "testing"
1919 "time"
2020
21+ "github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/cai"
2122 "github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/gcloud"
2223 "github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/golden"
2324 "github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/tft"
2425 "github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/utils"
2526 "github.com/gruntwork-io/terratest/modules/k8s"
2627 "github.com/stretchr/testify/assert"
2728 "github.com/terraform-google-modules/terraform-google-kubernetes-engine/test/integration/testutils"
28- gkeutils "github.com/terraform-google-modules/terraform-google-kubernetes-engine/test/integration/utils"
2929)
3030
3131func TestNodePool (t * testing.T ) {
@@ -36,15 +36,15 @@ func TestNodePool(t *testing.T) {
3636 bpt .DefineVerify (func (assert * assert.Assertions ) {
3737 // Skipping Default Verify as the Verify Stage fails due to change in Client Cert Token
3838 // bpt.DefaultVerify(assert)
39- gkeutils .TGKEVerify (t , bpt , assert ) // Verify Resources
39+ testutils .TGKEVerify (t , bpt , assert ) // Verify Resources
4040
4141 projectId := bpt .GetStringOutput ("project_id" )
4242 location := bpt .GetStringOutput ("location" )
4343 clusterName := bpt .GetStringOutput ("cluster_name" )
4444
4545 // CAI
4646 clusterResourceName := fmt .Sprintf ("//container.googleapis.com/projects/%s/locations/%s/clusters/%s" , projectId , location , clusterName )
47- cluster := gkeutils .GetProjectResources (t , projectId , gkeutils .WithAssetTypes ([]string {"container.googleapis.com/Cluster" })).Get ("#(name=\" " + clusterResourceName + "\" ).resource.data" )
47+ cluster := cai .GetProjectResources (t , projectId , cai .WithAssetTypes ([]string {"container.googleapis.com/Cluster" })).Get ("#(name=\" " + clusterResourceName + "\" ).resource.data" )
4848
4949 // Equivalent gcloud describe command
5050 // cluster := gcloud.Runf(t, "container clusters describe %s --zone %s --project %s", clusterName, location, projectId)
@@ -186,7 +186,7 @@ func TestNodePool(t *testing.T) {
186186 k8sOpts := k8s.KubectlOptions {}
187187 clusterNodesOp , err := k8s .RunKubectlAndGetOutputE (t , & k8sOpts , "get" , "nodes" , "-o" , "json" )
188188 assert .NoError (err )
189- clusterNodes := testutils .ParseKubectlJSONResult (t , clusterNodesOp )
189+ clusterNodes := utils .ParseKubectlJSONResult (t , clusterNodesOp )
190190 assert .JSONEq (`[
191191 {
192192 "effect": "PreferNoSchedule",
0 commit comments