add logging

Author: apeabody

test/integration/node_pool/node_pool_test.go

@@ -60,7 +60,7 @@ func TestNodePool(t *testing.T) {
 		)
 
 		// Cluster (and listed node pools) Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{"pool-01", "pool-02", "pool-03", "pool-04", "pool-05"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{"pool-01", "pool-02", "pool-03", "pool-04", "pool-05"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// K8s Assertions
 		assert.JSONEq(`[

test/integration/simple_regional_with_gateway_api/simple_regional_with_gateway_api_test.go

@@ -60,7 +60,7 @@ func TestSimpleRegionalWithGatewayAPI(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 	})
 	bpt.Test()
 }

test/integration/simple_regional_with_ipv6/simple_regional_with_ipv6_test.go

@@ -60,7 +60,7 @@ func TestSimpleRegionalWithGatewayAPI(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 	})
 	bpt.Test()
 }

test/integration/stub_domains/stub_domains_test.go

@@ -63,7 +63,7 @@ func TestStubDomains(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// K8s Assertions
 		// CAI does not include k8s.io/ConfigMap

test/integration/stub_domains_private/stub_domains_private_test.go

@@ -63,7 +63,7 @@ func TestStubDomainsPrivate(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// K8s Assertions
 		// CAI does not include k8s.io/ConfigMap

test/integration/stub_domains_upstream_nameservers/stub_domains_upstream_nameservers_test.go

@@ -63,7 +63,7 @@ func TestStubDomainsUpstreamNameservers(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// K8s Assertions
 		// CAI does not include k8s.io/ConfigMap

test/integration/testutils/utils.go

@@ -1,4 +1,4 @@
-// Copyright 2022-2024 Google LLC
+// Copyright 2022-2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -76,7 +76,7 @@ func TGKEVerifyExemptResources(t *testing.T, b *tft.TFBlueprintTest, assert *ass
 }
 
 // TGKEAssertGolden asserts a cluster and listed node pools against paths in golden image
-func TGKEAssertGolden(assert *assert.Assertions, golden *golden.GoldenFile, clusterJson *gjson.Result, nodePools []string, exemptClusterPaths []string) {
+func TGKEAssertGolden(t *testing.T, assert *assert.Assertions, golden *golden.GoldenFile, clusterJson *gjson.Result, nodePools []string, exemptClusterPaths []string) {
 	// Retrieve golden paths
 	clusterCheckPaths := utils.GetTerminalJSONPaths(golden.GetJSON())
 
@@ -90,6 +90,7 @@ func TGKEAssertGolden(assert *assert.Assertions, golden *golden.GoldenFile, clus
 		}
 		return false
 	})
+	t.Logf("Found %d cluster paths to check", len(clusterCheckPaths))
 
 	// Cluster assertions
 	golden.JSONPathEqs(assert, *clusterJson, clusterCheckPaths)
@@ -99,15 +100,18 @@ func TGKEAssertGolden(assert *assert.Assertions, golden *golden.GoldenFile, clus
 		assert.Truef(clusterJson.Get(fmt.Sprintf("nodePools.#(name==%s).name", nodePool)).Exists(), "NodePool not found: %s", nodePool)
 
 		nodeCheckPaths := utils.GetTerminalJSONPaths(golden.GetJSON().Get(fmt.Sprintf("nodePools.#(name==%s)", nodePool)))
+		t.Logf("Found %d node %q paths to check", len(nodeCheckPaths), nodePool)
 
 		syncGroup := new(errgroup.Group)
 		syncGroup.SetLimit(24)
-		for _, nodeCheckPath := range nodeCheckPaths {
-			nodeCheckPath := nodeCheckPath
+		for i, nodeCheckPath := range nodeCheckPaths {
+			i, nodeCheckPath := i, nodeCheckPath // https://golang.org/doc/faq#closures_and_goroutines
+			nodePool := nodePool
 			syncGroup.Go(func() error {
+				t.Logf("Checking path %d: %s", i, nodeCheckPath)
 				gotData := golden.ApplySanitizers(clusterJson.Get(fmt.Sprintf("nodePools.#(name==%s)", nodePool)).Get(nodeCheckPath).String())
 				gfData := golden.GetJSON().Get(fmt.Sprintf("nodePools.#(name==%s)", nodePool)).Get(nodeCheckPath).String()
-				assert.Equalf(gfData, gotData, "For node %s path %q expected %q to match fixture %q", nodePool, nodeCheckPath, gotData, gfData)
+				assert.Equalf(gfData, gotData, "For node %q path %q expected %q to match fixture %q", nodePool, nodeCheckPath, gotData, gfData)
 				return nil
 			})
 		}

test/integration/upstream_nameservers/upstream_nameservers_test.go

@@ -63,7 +63,7 @@ func TestUpstreamNameservers(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// K8s Assertions
 		// CAI does not include k8s.io/ConfigMap

test/integration/workload_metadata_config/workload_metadata_config_test.go

@@ -61,7 +61,7 @@ func TestWorkloadMetadataConfig(t *testing.T) {
 		)
 
 		// Cluster Assertions
-		testutils.TGKEAssertGolden(assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
+		testutils.TGKEAssertGolden(t, assert, g, &cluster, []string{"default-pool"}, []string{"monitoringConfig.componentConfig.enableComponents"}) // TODO: enableComponents is UL
 
 		// IAM Assertions
 		// CAI IAM data can be stale