github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-30 06:54:01 +00:00
Code Issues Projects Releases Wiki Activity

Reduce genericapiserver api surface

Browse Source
This commit is contained in:
Dr. Stefan Schimanski 2016-09-22 13:02:52 +02:00
parent 5af04d1dd1
commit c727e27602
4 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/apiserver/apiserver.go
View File

@ -97,7 +97,7 @@ func Run(serverOptions *genericoptions.ServerRunOptions) error {
Scheme: api.Scheme, Scheme: api.Scheme,
NegotiatedSerializer: api.Codecs, NegotiatedSerializer: api.Codecs,
} }
if err := s.InstallAPIGroups([]genericapiserver.APIGroupInfo{apiGroupInfo}); err != nil { if err := s.InstallAPIGroup(&apiGroupInfo); err != nil {
return fmt.Errorf("Error in installing API: %v", err) return fmt.Errorf("Error in installing API: %v", err)
} }
s.Run(serverOptions) s.Run(serverOptions)

12
pkg/genericapiserver/genericapiserver.go
View File

@ -225,16 +225,6 @@ func NewHandlerContainer(mux *http.ServeMux, s runtime.NegotiatedSerializer) *re
return container return container
} }
// Exposes the given group versions in API. Helper method to install multiple group versions at once.
func (s *GenericAPIServer) InstallAPIGroups(groupsInfo []APIGroupInfo) error {
for _, apiGroupInfo := range groupsInfo {
if err := s.InstallAPIGroup(&apiGroupInfo); err != nil {
return err
}
}
return nil
}
// Installs handler at /apis to list all group versions for discovery // Installs handler at /apis to list all group versions for discovery
func (s *GenericAPIServer) installGroupsDiscoveryHandler() { func (s *GenericAPIServer) installGroupsDiscoveryHandler() {
apiserver.AddApisWebService(s.Serializer, s.HandlerContainer, s.apiPrefix, func(req *restful.Request) []unversioned.APIGroup { apiserver.AddApisWebService(s.Serializer, s.HandlerContainer, s.apiPrefix, func(req *restful.Request) []unversioned.APIGroup {
@ -390,7 +380,7 @@ func (s *GenericAPIServer) Run(options *options.ServerRunOptions) {
select {} select {}
} }
// Exposes the given group version in API. // Exposes the given api group in the API.
func (s *GenericAPIServer) InstallAPIGroup(apiGroupInfo *APIGroupInfo) error { func (s *GenericAPIServer) InstallAPIGroup(apiGroupInfo *APIGroupInfo) error {
apiPrefix := s.apiPrefix apiPrefix := s.apiPrefix
if apiGroupInfo.IsLegacyGroup { if apiGroupInfo.IsLegacyGroup {

4
pkg/genericapiserver/genericapiserver_test.go
View File

@ -138,7 +138,9 @@ func TestInstallAPIGroups(t *testing.T) {
NegotiatedSerializer: api.Codecs, NegotiatedSerializer: api.Codecs,
}, },
} }
s.InstallAPIGroups(apiGroupsInfo) for i := range apiGroupsInfo {
s.InstallAPIGroup(&apiGroupsInfo[i])
}
server := httptest.NewServer(s.HandlerContainer.ServeMux) server := httptest.NewServer(s.HandlerContainer.ServeMux)
defer server.Close() defer server.Close()

4
pkg/master/master.go
View File

@ -331,10 +331,12 @@ func (m *Master) InstallAPIs(c *Config) {
apiGroupsInfo = append(apiGroupsInfo, apiGroupInfo) apiGroupsInfo = append(apiGroupsInfo, apiGroupInfo)
} }
if err := m.InstallAPIGroups(apiGroupsInfo); err != nil { for i := range apiGroupsInfo {
if err := m.InstallAPIGroup(&apiGroupsInfo[i]); err != nil {
glog.Fatalf("Error in registering group versions: %v", err) glog.Fatalf("Error in registering group versions: %v", err)
} }
} }
}
func (m *Master) initV1ResourcesStorage(c *Config) { func (m *Master) initV1ResourcesStorage(c *Config) {
restOptions := func(resource string) generic.RESTOptions { restOptions := func(resource string) generic.RESTOptions {