kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

handle registered third parties 

Kubernetes-commit: b512073457d02f326ac39d5774582a92c763c47f
This commit is contained in:
deads2k 2017-03-27 16:12:17 -04:00 committed by Kubernetes Publisher
parent ec0ac3b1aa
commit 4989e215f2
2 changed files with 28 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/endpoints/discovery/group.go
View File

@ -28,15 +28,15 @@ import (
"k8s.io/apiserver/pkg/endpoints/handlers/responsewriters" "k8s.io/apiserver/pkg/endpoints/handlers/responsewriters"
) )
// apiGroupHandler creates a webservice serving the supported versions, preferred version, and name // APIGroupHandler creates a webservice serving the supported versions, preferred version, and name
// of a group. E.g., such a web service will be registered at /apis/extensions. // of a group. E.g., such a web service will be registered at /apis/extensions.
type apiGroupHandler struct { type APIGroupHandler struct {
serializer runtime.NegotiatedSerializer serializer runtime.NegotiatedSerializer
group metav1.APIGroup group metav1.APIGroup
} }
func NewAPIGroupHandler(serializer runtime.NegotiatedSerializer, group metav1.APIGroup) *apiGroupHandler { func NewAPIGroupHandler(serializer runtime.NegotiatedSerializer, group metav1.APIGroup) *APIGroupHandler {
if keepUnversioned(group.Name) { if keepUnversioned(group.Name) {
// Because in release 1.1, /apis/extensions returns response with empty // Because in release 1.1, /apis/extensions returns response with empty
// APIVersion, we use stripVersionNegotiatedSerializer to keep the // APIVersion, we use stripVersionNegotiatedSerializer to keep the
@ -44,13 +44,13 @@ func NewAPIGroupHandler(serializer runtime.NegotiatedSerializer, group metav1.AP
serializer = stripVersionNegotiatedSerializer{serializer} serializer = stripVersionNegotiatedSerializer{serializer}
} }
return &apiGroupHandler{ return &APIGroupHandler{
serializer: serializer, serializer: serializer,
group: group, group: group,
} }
} }
func (s *apiGroupHandler) WebService() *restful.WebService { func (s *APIGroupHandler) WebService() *restful.WebService {
mediaTypes, _ := negotiation.MediaTypesForSerializer(s.serializer) mediaTypes, _ := negotiation.MediaTypesForSerializer(s.serializer)
ws := new(restful.WebService) ws := new(restful.WebService)
ws.Path(APIGroupPrefix + "/" + s.group.Name) ws.Path(APIGroupPrefix + "/" + s.group.Name)
@ -65,6 +65,10 @@ func (s *apiGroupHandler) WebService() *restful.WebService {
} }
// handle returns a handler which will return the api.GroupAndVersion of the group. // handle returns a handler which will return the api.GroupAndVersion of the group.
func (s *apiGroupHandler) handle(req *restful.Request, resp *restful.Response) { func (s *APIGroupHandler) handle(req *restful.Request, resp *restful.Response) {
responsewriters.WriteObjectNegotiated(s.serializer, schema.GroupVersion{}, resp.ResponseWriter, req.Request, http.StatusOK, &s.group) s.ServeHTTP(resp.ResponseWriter, req.Request)
}
func (s *APIGroupHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) {
responsewriters.WriteObjectNegotiated(s.serializer, schema.GroupVersion{}, w, req, http.StatusOK, &s.group)
} }

24
pkg/endpoints/discovery/version.go
View File

@ -32,16 +32,22 @@ type APIResourceLister interface {
ListAPIResources() []metav1.APIResource ListAPIResources() []metav1.APIResource
} }
// apiVersionHandler creates a webservice serving the supported resources for the version type APIResourceListerFunc func() []metav1.APIResource
func (f APIResourceListerFunc) ListAPIResources() []metav1.APIResource {
return f()
}
// APIVersionHandler creates a webservice serving the supported resources for the version
// E.g., such a web service will be registered at /apis/extensions/v1beta1. // E.g., such a web service will be registered at /apis/extensions/v1beta1.
type apiVersionHandler struct { type APIVersionHandler struct {
serializer runtime.NegotiatedSerializer serializer runtime.NegotiatedSerializer
groupVersion schema.GroupVersion groupVersion schema.GroupVersion
apiResourceLister APIResourceLister apiResourceLister APIResourceLister
} }
func NewAPIVersionHandler(serializer runtime.NegotiatedSerializer, groupVersion schema.GroupVersion, apiResourceLister APIResourceLister) *apiVersionHandler { func NewAPIVersionHandler(serializer runtime.NegotiatedSerializer, groupVersion schema.GroupVersion, apiResourceLister APIResourceLister) *APIVersionHandler {
if keepUnversioned(groupVersion.Group) { if keepUnversioned(groupVersion.Group) {
// Because in release 1.1, /apis/extensions returns response with empty // Because in release 1.1, /apis/extensions returns response with empty
// APIVersion, we use stripVersionNegotiatedSerializer to keep the // APIVersion, we use stripVersionNegotiatedSerializer to keep the
@ -49,14 +55,14 @@ func NewAPIVersionHandler(serializer runtime.NegotiatedSerializer, groupVersion
serializer = stripVersionNegotiatedSerializer{serializer} serializer = stripVersionNegotiatedSerializer{serializer}
} }
return &apiVersionHandler{ return &APIVersionHandler{
serializer: serializer, serializer: serializer,
groupVersion: groupVersion, groupVersion: groupVersion,
apiResourceLister: apiResourceLister, apiResourceLister: apiResourceLister,
} }
} }
func (s *apiVersionHandler) AddToWebService(ws *restful.WebService) { func (s *APIVersionHandler) AddToWebService(ws *restful.WebService) {
mediaTypes, _ := negotiation.MediaTypesForSerializer(s.serializer) mediaTypes, _ := negotiation.MediaTypesForSerializer(s.serializer)
ws.Route(ws.GET("/").To(s.handle). ws.Route(ws.GET("/").To(s.handle).
Doc("get available resources"). Doc("get available resources").
@ -67,7 +73,11 @@ func (s *apiVersionHandler) AddToWebService(ws *restful.WebService) {
} }
// handle returns a handler which will return the api.VersionAndVersion of the group. // handle returns a handler which will return the api.VersionAndVersion of the group.
func (s *apiVersionHandler) handle(req *restful.Request, resp *restful.Response) { func (s *APIVersionHandler) handle(req *restful.Request, resp *restful.Response) {
responsewriters.WriteObjectNegotiated(s.serializer, schema.GroupVersion{}, resp.ResponseWriter, req.Request, http.StatusOK, s.ServeHTTP(resp.ResponseWriter, req.Request)
}
func (s *APIVersionHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) {
responsewriters.WriteObjectNegotiated(s.serializer, schema.GroupVersion{}, w, req, http.StatusOK,
&metav1.APIResourceList{GroupVersion: s.groupVersion.String(), APIResources: s.apiResourceLister.ListAPIResources()}) &metav1.APIResourceList{GroupVersion: s.groupVersion.String(), APIResources: s.apiResourceLister.ListAPIResources()})
} }