git subrepo clone (merge) https://github.com/kubernetes-incubator/metrics-server.git metrics-server
subrepo:
subdir: "metrics-server"
merged: "92d8412"
upstream:
origin: "https://github.com/kubernetes-incubator/metrics-server.git"
branch: "master"
commit: "92d8412"
git-subrepo:
version: "0.4.0"
origin: "???"
commit: "???"
diff --git a/metrics-server/vendor/k8s.io/kube-openapi/pkg/handler/handler.go b/metrics-server/vendor/k8s.io/kube-openapi/pkg/handler/handler.go
new file mode 100644
index 0000000..c4bbc0b
--- /dev/null
+++ b/metrics-server/vendor/k8s.io/kube-openapi/pkg/handler/handler.go
@@ -0,0 +1,272 @@
+/*
+Copyright 2017 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package handler
+
+import (
+ "bytes"
+ "compress/gzip"
+ "crypto/sha512"
+ "encoding/json"
+ "fmt"
+ "mime"
+ "net/http"
+ "strings"
+ "sync"
+ "time"
+
+ "bitbucket.org/ww/goautoneg"
+
+ yaml "gopkg.in/yaml.v2"
+
+ "github.com/NYTimes/gziphandler"
+ restful "github.com/emicklei/go-restful"
+ "github.com/go-openapi/spec"
+ "github.com/golang/protobuf/proto"
+ openapi_v2 "github.com/googleapis/gnostic/OpenAPIv2"
+ "github.com/googleapis/gnostic/compiler"
+
+ "k8s.io/kube-openapi/pkg/builder"
+ "k8s.io/kube-openapi/pkg/common"
+)
+
+const (
+ jsonExt = ".json"
+
+ mimeJson = "application/json"
+ // TODO(mehdy): change @68f4ded to a version tag when gnostic add version tags.
+ mimePb = "application/com.github.googleapis.gnostic.OpenAPIv2@68f4ded+protobuf"
+ mimePbGz = "application/x-gzip"
+)
+
+// OpenAPIService is the service responsible for serving OpenAPI spec. It has
+// the ability to safely change the spec while serving it.
+type OpenAPIService struct {
+ // rwMutex protects All members of this service.
+ rwMutex sync.RWMutex
+
+ lastModified time.Time
+
+ specBytes []byte
+ specPb []byte
+ specPbGz []byte
+
+ specBytesETag string
+ specPbETag string
+ specPbGzETag string
+}
+
+func init() {
+ mime.AddExtensionType(".json", mimeJson)
+ mime.AddExtensionType(".pb-v1", mimePb)
+ mime.AddExtensionType(".gz", mimePbGz)
+}
+
+func computeETag(data []byte) string {
+ return fmt.Sprintf("\"%X\"", sha512.Sum512(data))
+}
+
+// NOTE: [DEPRECATION] We will announce deprecation for format-separated endpoints for OpenAPI spec,
+// and switch to a single /openapi/v2 endpoint in Kubernetes 1.10. The design doc and deprecation process
+// are tracked at: https://docs.google.com/document/d/19lEqE9lc4yHJ3WJAJxS_G7TcORIJXGHyq3wpwcH28nU.
+//
+// BuildAndRegisterOpenAPIService builds the spec and registers a handler to provide access to it.
+// Use this method if your OpenAPI spec is static. If you want to update the spec, use BuildOpenAPISpec then RegisterOpenAPIService.
+func BuildAndRegisterOpenAPIService(servePath string, webServices []*restful.WebService, config *common.Config, handler common.PathHandler) (*OpenAPIService, error) {
+ spec, err := builder.BuildOpenAPISpec(webServices, config)
+ if err != nil {
+ return nil, err
+ }
+ return RegisterOpenAPIService(spec, servePath, handler)
+}
+
+// NOTE: [DEPRECATION] We will announce deprecation for format-separated endpoints for OpenAPI spec,
+// and switch to a single /openapi/v2 endpoint in Kubernetes 1.10. The design doc and deprecation process
+// are tracked at: https://docs.google.com/document/d/19lEqE9lc4yHJ3WJAJxS_G7TcORIJXGHyq3wpwcH28nU.
+//
+// RegisterOpenAPIService registers a handler to provide access to provided swagger spec.
+// Note: servePath should end with ".json" as the RegisterOpenAPIService assume it is serving a
+// json file and will also serve .pb and .gz files.
+func RegisterOpenAPIService(openapiSpec *spec.Swagger, servePath string, handler common.PathHandler) (*OpenAPIService, error) {
+ if !strings.HasSuffix(servePath, jsonExt) {
+ return nil, fmt.Errorf("serving path must end with \"%s\"", jsonExt)
+ }
+
+ servePathBase := strings.TrimSuffix(servePath, jsonExt)
+
+ o := OpenAPIService{}
+ if err := o.UpdateSpec(openapiSpec); err != nil {
+ return nil, err
+ }
+
+ type fileInfo struct {
+ ext string
+ getDataAndETag func() ([]byte, string, time.Time)
+ }
+
+ files := []fileInfo{
+ {".json", o.getSwaggerBytes},
+ {"-2.0.0.json", o.getSwaggerBytes},
+ {"-2.0.0.pb-v1", o.getSwaggerPbBytes},
+ {"-2.0.0.pb-v1.gz", o.getSwaggerPbGzBytes},
+ }
+
+ for _, file := range files {
+ path := servePathBase + file.ext
+ getDataAndETag := file.getDataAndETag
+ handler.Handle(path, gziphandler.GzipHandler(http.HandlerFunc(
+ func(w http.ResponseWriter, r *http.Request) {
+ data, etag, lastModified := getDataAndETag()
+ w.Header().Set("Etag", etag)
+
+ // ServeContent will take care of caching using eTag.
+ http.ServeContent(w, r, path, lastModified, bytes.NewReader(data))
+ }),
+ ))
+ }
+
+ return &o, nil
+}
+
+func (o *OpenAPIService) getSwaggerBytes() ([]byte, string, time.Time) {
+ o.rwMutex.RLock()
+ defer o.rwMutex.RUnlock()
+ return o.specBytes, o.specBytesETag, o.lastModified
+}
+
+func (o *OpenAPIService) getSwaggerPbBytes() ([]byte, string, time.Time) {
+ o.rwMutex.RLock()
+ defer o.rwMutex.RUnlock()
+ return o.specPb, o.specPbETag, o.lastModified
+}
+
+func (o *OpenAPIService) getSwaggerPbGzBytes() ([]byte, string, time.Time) {
+ o.rwMutex.RLock()
+ defer o.rwMutex.RUnlock()
+ return o.specPbGz, o.specPbGzETag, o.lastModified
+}
+
+func (o *OpenAPIService) UpdateSpec(openapiSpec *spec.Swagger) (err error) {
+ specBytes, err := json.MarshalIndent(openapiSpec, " ", " ")
+ if err != nil {
+ return err
+ }
+ specPb, err := toProtoBinary(specBytes)
+ if err != nil {
+ return err
+ }
+ specPbGz := toGzip(specPb)
+
+ specBytesETag := computeETag(specBytes)
+ specPbETag := computeETag(specPb)
+ specPbGzETag := computeETag(specPbGz)
+
+ lastModified := time.Now()
+
+ o.rwMutex.Lock()
+ defer o.rwMutex.Unlock()
+
+ o.specBytes = specBytes
+ o.specPb = specPb
+ o.specPbGz = specPbGz
+ o.specBytesETag = specBytesETag
+ o.specPbETag = specPbETag
+ o.specPbGzETag = specPbGzETag
+ o.lastModified = lastModified
+
+ return nil
+}
+
+func toProtoBinary(spec []byte) ([]byte, error) {
+ var info yaml.MapSlice
+ err := yaml.Unmarshal(spec, &info)
+ if err != nil {
+ return nil, err
+ }
+ document, err := openapi_v2.NewDocument(info, compiler.NewContext("$root", nil))
+ if err != nil {
+ return nil, err
+ }
+ return proto.Marshal(document)
+}
+
+func toGzip(data []byte) []byte {
+ var buf bytes.Buffer
+ zw := gzip.NewWriter(&buf)
+ zw.Write(data)
+ zw.Close()
+ return buf.Bytes()
+}
+
+// RegisterOpenAPIVersionedService registers a handler to provide access to provided swagger spec.
+func RegisterOpenAPIVersionedService(openapiSpec *spec.Swagger, servePath string, handler common.PathHandler) (*OpenAPIService, error) {
+ o := OpenAPIService{}
+ if err := o.UpdateSpec(openapiSpec); err != nil {
+ return nil, err
+ }
+
+ accepted := []struct {
+ Type string
+ SubType string
+ GetDataAndETag func() ([]byte, string, time.Time)
+ }{
+ {"application", "json", o.getSwaggerBytes},
+ {"application", "com.github.proto-openapi.spec.v2@v1.0+protobuf", o.getSwaggerPbBytes},
+ }
+
+ handler.Handle(servePath, gziphandler.GzipHandler(http.HandlerFunc(
+ func(w http.ResponseWriter, r *http.Request) {
+ decipherableFormats := r.Header.Get("Accept")
+ if decipherableFormats == "" {
+ decipherableFormats = "*/*"
+ }
+ clauses := goautoneg.ParseAccept(decipherableFormats)
+ w.Header().Add("Vary", "Accept")
+ for _, clause := range clauses {
+ for _, accepts := range accepted {
+ if clause.Type != accepts.Type && clause.Type != "*" {
+ continue
+ }
+ if clause.SubType != accepts.SubType && clause.SubType != "*" {
+ continue
+ }
+
+ // serve the first matching media type in the sorted clause list
+ data, etag, lastModified := accepts.GetDataAndETag()
+ w.Header().Set("Etag", etag)
+ // ServeContent will take care of caching using eTag.
+ http.ServeContent(w, r, servePath, lastModified, bytes.NewReader(data))
+ return
+ }
+ }
+ // Return 406 for not acceptable format
+ w.WriteHeader(406)
+ return
+ }),
+ ))
+
+ return &o, nil
+}
+
+// BuildAndRegisterOpenAPIVersionedService builds the spec and registers a handler to provide access to it.
+// Use this method if your OpenAPI spec is static. If you want to update the spec, use BuildOpenAPISpec then RegisterOpenAPIVersionedService.
+func BuildAndRegisterOpenAPIVersionedService(servePath string, webServices []*restful.WebService, config *common.Config, handler common.PathHandler) (*OpenAPIService, error) {
+ spec, err := builder.BuildOpenAPISpec(webServices, config)
+ if err != nil {
+ return nil, err
+ }
+ return RegisterOpenAPIVersionedService(spec, servePath, handler)
+}