fix: fix proxy mode option image not work bug (#146)

kubenetworks · Feb 6, 2024 · 59abb16 · 59abb16
1 parent 6a23247
commit 59abb16
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/pkg/daemon/action/proxy.go b/pkg/daemon/action/proxy.go
@@ -28,6 +28,7 @@ func (svr *Server) Proxy(req *rpc.ConnectRequest, resp rpc.Daemon_ProxyServer) e
 		log.SetOutput(svr.LogFile)
 		log.SetLevel(log.DebugLevel)
 	}()
+	config.Image = req.Image
 	config.Debug = req.Level == int32(log.DebugLevel)
 	log.SetLevel(log.InfoLevel)
 	ctx := resp.Context()

diff --git a/pkg/handler/remote.go b/pkg/handler/remote.go
@@ -53,7 +53,7 @@ func createOutboundPod(ctx context.Context, factory cmdutil.Factory, clientset *
 				return
 			}
 			log.Infoln("traffic manager already exist, reuse it")
-			return nil
+			return
 		}
 	}
 	var deleteResource = func(ctx context.Context) {
@@ -163,22 +163,22 @@ func createOutboundPod(ctx context.Context, factory cmdutil.Factory, clientset *
 				Name:       udp8422,
 				Protocol:   v1.ProtocolUDP,
 				Port:       8422,
-				TargetPort: intstr.FromInt(8422),
+				TargetPort: intstr.FromInt32(8422),
 			}, {
 				Name:       tcp10800,
 				Protocol:   v1.ProtocolTCP,
 				Port:       10800,
-				TargetPort: intstr.FromInt(10800),
+				TargetPort: intstr.FromInt32(10800),
 			}, {
 				Name:       tcp9002,
 				Protocol:   v1.ProtocolTCP,
 				Port:       9002,
-				TargetPort: intstr.FromInt(9002),
+				TargetPort: intstr.FromInt32(9002),
 			}, {
 				Name:       tcp80,
 				Protocol:   v1.ProtocolTCP,
 				Port:       80,
-				TargetPort: intstr.FromInt(80),
+				TargetPort: intstr.FromInt32(80),
 			}},
 			Selector: map[string]string{"app": config.ConfigMapPodTrafficManager},
 			Type:     v1.ServiceTypeClusterIP,