Parcourir la source

add groupversion and set NegotiatedSerializer

Mohammed Nafees il y a 4 ans
Parent
commit
e0612a0e8b
1 fichiers modifiés avec 15 ajouts et 6 suppressions
  1. 15 6
      cli/cmd/portforward.go

+ 15 - 6
cli/cmd/portforward.go

@@ -18,6 +18,8 @@ import (
 	"github.com/spf13/cobra"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
@@ -163,6 +165,19 @@ func portForward(user *types.GetAuthenticatedUserResponse, client *api.Client, a
 		return err
 	}
 
+	restConf.GroupVersion = &schema.GroupVersion{
+		Group:   "api",
+		Version: "v1",
+	}
+
+	restConf.NegotiatedSerializer = runtime.NewSimpleNegotiatedSerializer(runtime.SerializerInfo{})
+
+	restClient, err := rest.RESTClientFor(restConf)
+
+	if err != nil {
+		return err
+	}
+
 	err = checkUDPPortInPod(args[1:], &pod)
 
 	if err != nil {
@@ -189,12 +204,6 @@ func portForward(user *types.GetAuthenticatedUserResponse, client *api.Client, a
 		}
 	}()
 
-	restClient, err := rest.RESTClientFor(restConf)
-
-	if err != nil {
-		return err
-	}
-
 	req := restClient.Post().
 		Resource("pods").
 		Namespace(namespace).