add flag to poenable rt forward ting of he loadbalancer ports

Change-Id: Ide7ec2da641da3ec0f7c51413a692c356d65bf56

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 {