feat(platform): proxy cluster version api

Author: leoryu

pkg/apiserver/filter/authentication.go

@@ -75,7 +75,6 @@ var (
 		"/metrics",
 		"/debug",
 		"/openapi",
-		"/version",
 		"/swagger",
 		"/favicon.ico",
 		"/healthz",

pkg/apiserver/openapi/openapi.go

@@ -25,7 +25,6 @@ import (
 	"strings"
 
 	"github.com/go-openapi/spec"
-	"k8s.io/apimachinery/pkg/version"
 	openapinamer "k8s.io/apiserver/pkg/endpoints/openapi"
 	genericapiserver "k8s.io/apiserver/pkg/server"
 	openapicommon "k8s.io/kube-openapi/pkg/common"
@@ -44,14 +43,6 @@ func SetupOpenAPI(genericAPIServerConfig *genericapiserver.Config, getDefinition
 	genericAPIServerConfig.OpenAPIConfig.Info.Version = appVersion.GitVersion
 	genericAPIServerConfig.OpenAPIConfig.PostProcessSpec = postProcessOpenAPISpec(host, port)
 
-	// version
-	genericAPIServerConfig.Version = &version.Info{
-		GitVersion: appVersion.GitVersion,
-		BuildDate:  appVersion.BuildDate,
-		GoVersion:  appVersion.GoVersion,
-		Compiler:   appVersion.Compiler,
-		Platform:   appVersion.Platform,
-	}
 }
 
 func postProcessOpenAPISpec(host string, port int) func(*spec.Swagger) (*spec.Swagger, error) {

pkg/platform/apiserver/apiserver.go

@@ -203,6 +203,9 @@ func (m *APIServer) InstallAPIs(apiResourceConfigSource serverstorage.APIResourc
 		apiGroupsInfo = append(apiGroupsInfo, apiGroupInfo)
 	}
 
+	versionHandler := NewVersionProxyHandler(m.GenericAPIServer.LoopbackClientConfig)
+	versionHandler.Install(m.GenericAPIServer.Handler.GoRestfulContainer)
+
 	for i := range apiGroupsInfo {
 		if err := m.GenericAPIServer.InstallAPIGroup(&apiGroupsInfo[i]); err != nil {
 			log.Fatalf("Error in registering group versions: %v", err)

pkg/platform/apiserver/versionproxy.go

@@ -0,0 +1,51 @@
+package apiserver
+
+import (
+	"net/http"
+
+	"github.com/emicklei/go-restful"
+	"k8s.io/client-go/rest"
+	platforminternalclient "tkestack.io/tke/api/client/clientset/internalversion/typed/platform/internalversion"
+	"tkestack.io/tke/pkg/platform/proxy"
+)
+
+type VersionProxyHandler struct {
+	config *rest.Config
+}
+
+func NewVersionProxyHandler(config *rest.Config) *VersionProxyHandler {
+	return &VersionProxyHandler{
+		config: config,
+	}
+}
+
+func (s *VersionProxyHandler) Install(c *restful.Container) {
+	versionWS := new(restful.WebService)
+	versionWS.Path("/version")
+	versionWS.Doc("git code version from which this is built")
+	versionWS.Route(
+		versionWS.GET("/").To(s.handle).
+			Doc("get the code version").
+			Operation("getVersion").
+			Produces(restful.MIME_JSON).
+			Consumes(restful.MIME_JSON))
+
+	c.Add(versionWS)
+}
+
+func (s *VersionProxyHandler) handle(req *restful.Request, resp *restful.Response) {
+	platformClient := platforminternalclient.NewForConfigOrDie(s.config)
+	client, err := proxy.ClientSet(req.Request.Context(), platformClient)
+	if err != nil {
+		resp.WriteHeaderAndEntity(http.StatusBadRequest, "err1"+err.Error())
+		return
+	}
+	version, err := client.Discovery().ServerVersion()
+
+	if err != nil {
+		resp.WriteHeaderAndEntity(http.StatusInternalServerError, "err2"+err.Error())
+		return
+	}
+
+	resp.WriteHeaderAndEntity(http.StatusOK, version)
+}