switch to nodeport

terraform/eks/e2e/main.tf

@@ -52,6 +52,15 @@ resource "aws_eks_node_group" "this" {
   ]
 }
 
+resource "aws_security_group_rule" "nodeport_inbound" {
+  type              = "ingress"
+  from_port         = 30080
+  to_port           = 30080
+  protocol          = "tcp"
+  cidr_blocks       = ["0.0.0.0/0"]
+  security_group_id = aws_eks_cluster.this.vpc_config[0].cluster_security_group_id
+}
+
 resource "aws_iam_role" "node_role" {
   name = "${local.cluster_name}-Worker-Role-${module.common.testing_id}"
 

test/e2e/jmx/jmx_test.go

@@ -330,15 +330,15 @@ func validateMetrics(t *testing.T, metrics []string, namespace string) {
 }
 
 func generateTraffic(t *testing.T) {
-	cmd := exec.Command("kubectl", "get", "svc", "tomcat-service", "-n", "test", "-o", "jsonpath='{.status.loadBalancer.ingress[0].hostname}'")
+	cmd := exec.Command("kubectl", "get", "nodes", "-o", "jsonpath='{.items[0].status.addresses[?(@.type==\"ExternalIP\")].address}'")
 	output, err := cmd.CombinedOutput()
-	require.NoError(t, err, "Error getting LoadBalancer URL")
+	require.NoError(t, err, "Error getting node external IP")
 
-	lbURL := strings.Trim(string(output), "'")
-	require.NotEmpty(t, lbURL, "LoadBalancer URL failed to format")
+	nodeIP := strings.Trim(string(output), "'")
+	require.NotEmpty(t, nodeIP, "Node IP failed to format")
 
 	for i := 0; i < 5; i++ {
-		resp, err := http.Get(fmt.Sprintf("http://%s/webapp/index.jsp", lbURL))
+		resp, err := http.Get(fmt.Sprintf("http://%s:30080/webapp/index.jsp", nodeIP))
 		if err != nil {
 			t.Logf("Request attempt %d failed: %v", i+1, err)
 			continue

test/e2e/jmx/resources/sample_apps/tomcat.yaml

@@ -9,12 +9,13 @@ metadata:
   name: tomcat-service
   namespace: test
 spec:
-  type: LoadBalancer
+  type: NodePort
   selector:
     app: tomcat
   ports:
     - port: 80
       targetPort: 8080
+      nodePort: 30080
 ---
 apiVersion: apps/v1
 kind: Deployment