mirror of
https://github.com/kubernetes-sigs/prometheus-adapter.git
synced 2026-04-06 17:57:51 +00:00
a293b2bf94
Travis seems to be having issues pulling deps, so we'll have to check in the vendor directory and prevent the makefile from trying to regenerate it normally.
114 lines
4.2 KiB
Go
114 lines
4.2 KiB
Go
/*
|
|
Copyright 2014 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 endpoints
|
|
|
|
import (
|
|
"path"
|
|
"time"
|
|
|
|
"github.com/emicklei/go-restful"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
utilerrors "k8s.io/apimachinery/pkg/util/errors"
|
|
"k8s.io/apimachinery/pkg/util/sets"
|
|
"k8s.io/apiserver/pkg/admission"
|
|
"k8s.io/apiserver/pkg/endpoints/discovery"
|
|
"k8s.io/apiserver/pkg/registry/rest"
|
|
openapicommon "k8s.io/kube-openapi/pkg/common"
|
|
)
|
|
|
|
// APIGroupVersion is a helper for exposing rest.Storage objects as http.Handlers via go-restful
|
|
// It handles URLs of the form:
|
|
// /${storage_key}[/${object_name}]
|
|
// Where 'storage_key' points to a rest.Storage object stored in storage.
|
|
// This object should contain all parameterization necessary for running a particular API version
|
|
type APIGroupVersion struct {
|
|
Storage map[string]rest.Storage
|
|
|
|
Root string
|
|
|
|
// GroupVersion is the external group version
|
|
GroupVersion schema.GroupVersion
|
|
|
|
// OptionsExternalVersion controls the Kubernetes APIVersion used for common objects in the apiserver
|
|
// schema like api.Status, api.DeleteOptions, and metav1.ListOptions. Other implementors may
|
|
// define a version "v1beta1" but want to use the Kubernetes "v1" internal objects. If
|
|
// empty, defaults to GroupVersion.
|
|
OptionsExternalVersion *schema.GroupVersion
|
|
// MetaGroupVersion defaults to "meta.k8s.io/v1" and is the scheme group version used to decode
|
|
// common API implementations like ListOptions. Future changes will allow this to vary by group
|
|
// version (for when the inevitable meta/v2 group emerges).
|
|
MetaGroupVersion *schema.GroupVersion
|
|
|
|
// RootScopedKinds are the root scoped kinds for the primary GroupVersion
|
|
RootScopedKinds sets.String
|
|
|
|
// Serializer is used to determine how to convert responses from API methods into bytes to send over
|
|
// the wire.
|
|
Serializer runtime.NegotiatedSerializer
|
|
ParameterCodec runtime.ParameterCodec
|
|
|
|
Typer runtime.ObjectTyper
|
|
Creater runtime.ObjectCreater
|
|
Convertor runtime.ObjectConvertor
|
|
Defaulter runtime.ObjectDefaulter
|
|
Linker runtime.SelfLinker
|
|
UnsafeConvertor runtime.ObjectConvertor
|
|
|
|
Admit admission.Interface
|
|
|
|
MinRequestTimeout time.Duration
|
|
|
|
// EnableAPIResponseCompression indicates whether API Responses should support compression
|
|
// if the client requests it via Accept-Encoding
|
|
EnableAPIResponseCompression bool
|
|
|
|
// OpenAPIConfig lets the individual handlers build a subset of the OpenAPI schema before they are installed.
|
|
OpenAPIConfig *openapicommon.Config
|
|
}
|
|
|
|
// InstallREST registers the REST handlers (storage, watch, proxy and redirect) into a restful Container.
|
|
// It is expected that the provided path root prefix will serve all operations. Root MUST NOT end
|
|
// in a slash.
|
|
func (g *APIGroupVersion) InstallREST(container *restful.Container) error {
|
|
prefix := path.Join(g.Root, g.GroupVersion.Group, g.GroupVersion.Version)
|
|
installer := &APIInstaller{
|
|
group: g,
|
|
prefix: prefix,
|
|
minRequestTimeout: g.MinRequestTimeout,
|
|
enableAPIResponseCompression: g.EnableAPIResponseCompression,
|
|
}
|
|
|
|
apiResources, ws, registrationErrors := installer.Install()
|
|
versionDiscoveryHandler := discovery.NewAPIVersionHandler(g.Serializer, g.GroupVersion, staticLister{apiResources})
|
|
versionDiscoveryHandler.AddToWebService(ws)
|
|
container.Add(ws)
|
|
return utilerrors.NewAggregate(registrationErrors)
|
|
}
|
|
|
|
// staticLister implements the APIResourceLister interface
|
|
type staticLister struct {
|
|
list []metav1.APIResource
|
|
}
|
|
|
|
func (s staticLister) ListAPIResources() []metav1.APIResource {
|
|
return s.list
|
|
}
|
|
|
|
var _ discovery.APIResourceLister = &staticLister{}
|