add flag to poenable rt forward ting of he loadbalancer ports

Change-Id: Ide7ec2da641da3ec0f7c51413a692c356d65bf56

Author: aojea

cmd/app.go

@@ -21,15 +21,17 @@ import (
 )
 
 var (
-	flagV         int
-	enableLogDump bool
-	logDumpDir    string
+	flagV               int
+	enableLogDump       bool
+	logDumpDir          string
+	enableLBPortMapping bool
 )
 
 func init() {
 	flag.IntVar(&flagV, "v", 2, "Verbosity level")
 	flag.BoolVar(&enableLogDump, "enable-log-dumping", false, "store logs to a temporal directory or to the directory specified using the logs-dir flag")
 	flag.StringVar(&logDumpDir, "logs-dir", "", "store logs to the specified directory")
+	flag.BoolVar(&enableLBPortMapping, "enable-lb-port-mapping", false, "enable port-mapping on the load balancer ports")
 
 	flag.Usage = func() {
 		fmt.Fprint(os.Stderr, "Usage: cloud-provider-kind [options]\n\n")
@@ -106,6 +108,11 @@ func Main() {
 		config.DefaultConfig.LoadBalancerConnectivity = config.Tunnel
 	}
 
+	// flag overrides autodetection
+	if enableLBPortMapping {
+		config.DefaultConfig.LoadBalancerConnectivity = config.Portmap
+	}
+
 	// default control plane connectivity to portmap, it will be
 	// overriden if the first cluster added detects direct
 	// connecitivity

pkg/loadbalancer/server.go

@@ -220,7 +220,8 @@ func (s *Server) createLoadBalancer(clusterName string, service *v1.Service, ima
 		}...)
 	}
 
-	if s.tunnelManager != nil {
+	if s.tunnelManager != nil ||
+		config.DefaultConfig.LoadBalancerConnectivity == config.Portmap {
 		// Forward the Service Ports to the host so they are accessible on Mac and Windows
 		for _, port := range service.Spec.Ports {
 			if port.Protocol != v1.ProtocolTCP && port.Protocol != v1.ProtocolUDP {