more fixups

cmd/expose.go

@@ -177,6 +177,10 @@ ktunnel expose redis 6379
 
 		// Kube Service
 		kubeService, err := k8s.NewKubeService(KubeContext, Namespace)
+		if err != nil {
+			log.Fatalf("Failed to start k8s clients: %v", err)
+			os.Exit(1)
+		}
 		// port-Forward
 		strPort := strconv.FormatInt(int64(port), 10)
 		stopChan := make(chan struct{}, 1)

cmd/server.go

@@ -32,10 +32,10 @@ ktunnel server -p 8181
 		// Run tunnel client and establish connection
 
 		sigs := make(chan os.Signal, 1)
-		signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM, syscall.SIGKILL, syscall.SIGQUIT)
+		signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)
 		go func() {
 			o.Do(func() {
-				_ = <-sigs
+				<-sigs
 				log.Info("Got exit signal, closing client tunnels")
 				cancel()
 			})

pkg/client/client.go

@@ -1,3 +1,4 @@
+// Package client implements the ktunnel client
 package client
 
 import (
@@ -18,11 +19,6 @@ import (
 	"google.golang.org/grpc/credentials/insecure"
 )
 
-type Message struct {
-	c *net.Conn
-	d *[]byte
-}
-
 func ReceiveData(conf *Config, st pb.Tunnel_InitTunnelClient, sessionsOut chan<- *common.Session, host string, port int32, scheme string) {
 loop:
 	for {
@@ -39,15 +35,15 @@ loop:
 				break loop
 			}
 
-			requestId, err := uuid.Parse(m.RequestId)
+			requestId, err := uuid.Parse(m.RequestID)
 			if err != nil {
-				conf.log.WithError(err).WithField("session", m.RequestId).Errorf("failed parsing session uuid from stream, skipping")
+				conf.log.WithError(err).WithField("session", m.RequestID).Errorf("failed parsing session uuid from stream, skipping")
 			}
 
 			session, exists := common.GetSession(requestId)
 			if exists == false {
 				conf.log.WithFields(log.Fields{
-					"session": m.RequestId,
+					"session": m.RequestID,
 					"host":    host,
 					"port":    port,
 				}).Infof("new connection")

pkg/server/server.go

@@ -48,7 +48,7 @@ func SendData(conf *Config, stream pb.Tunnel_InitTunnelServer, sessions <-chan *
 				HasErr:      false,
 				LogMessage:  nil,
 				Data:        bytes,
-				RequestId:   session.Id.String(),
+				RequestID:   session.Id.String(),
 				ShouldClose: !session.Open,
 			}
 			session.Unlock()