support also checks for ipv6 endpoints

gardener · Oct 15, 2024 · e3934e5 · e3934e5
1 parent 610f0eb
commit e3934e5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/agent/runners/checktcpport.go b/pkg/agent/runners/checktcpport.go
@@ -12,8 +12,8 @@ import (
 	"time"
 
 	"github.com/gardener/network-problem-detector/pkg/common/config"
-
 	"github.com/spf13/cobra"
+	k8snetutils "k8s.io/utils/net"
 )
 
 type checkTCPPortArgs struct {
@@ -123,6 +123,9 @@ var _ Runner = &checkTCPPort{}
 
 func checkTCPPortFunc(endpoint config.Endpoint) (string, error) {
 	addr := fmt.Sprintf("%s:%d", endpoint.IP, endpoint.Port)
+	if k8snetutils.IsIPv6(net.ParseIP(endpoint.IP)) {
+		addr = fmt.Sprintf("[%s]:%d", endpoint.IP, endpoint.Port)
+	}
 	conn, err := net.DialTimeout("tcp", addr, 30*time.Second)
 	if err != nil {
 		return "", err