tests/e2e/k8s/services/httpecho: Use a fresh connection

This commit changes the httpecho client to use a fresh connection per each request.

Signed-off-by: Or Ozeri <[email protected]>

tests/e2e/k8s/services/httpecho/client.go

@@ -22,6 +22,7 @@ import (
 	"strconv"
 	"strings"
 	"syscall"
+	"time"
 
 	k8serr "k8s.io/apimachinery/pkg/api/errors"
 
@@ -38,14 +39,16 @@ func GetEchoValue(cluster *util.KindCluster, server *util.Service) (string, erro
 		return "", err
 	}
 
-	url := fmt.Sprintf("http://%s", net.JoinHostPort(cluster.IP(), strconv.Itoa(int(port))))
-	req, err := http.NewRequest(http.MethodGet, url, nil)
-	if err != nil {
-		return "", fmt.Errorf("cannot create request: %w", err)
+	// fresh client assures a fresh connection
+	client := &http.Client{
+		Transport: &http.Transport{
+			DisableKeepAlives: true,
+		},
+		Timeout:   1 * time.Second,
 	}
 
-	req.Close = true
-	resp, err := http.DefaultClient.Do(req)
+	url := fmt.Sprintf("http://%s", net.JoinHostPort(cluster.IP(), strconv.Itoa(int(port))))
+	resp, err := client.Get(url)
 	if err != nil {
 		if errors.Is(err, syscall.ECONNREFUSED) {
 			return "", &services.ConnectionRefusedError{}