Commit 1063903d authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub

Merge pull request #33266 from sttts/sttts-one-installapigroups

Automatic merge from submit-queue Reduce genericapiserver api surface
parents 7144f54d c727e276
...@@ -98,7 +98,7 @@ func Run(serverOptions *genericoptions.ServerRunOptions) error { ...@@ -98,7 +98,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)
......
...@@ -216,16 +216,6 @@ func NewHandlerContainer(mux *http.ServeMux, s runtime.NegotiatedSerializer) *re ...@@ -216,16 +216,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 {
...@@ -384,7 +374,7 @@ func (s *GenericAPIServer) Run(options *options.ServerRunOptions) { ...@@ -384,7 +374,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 {
......
...@@ -138,7 +138,9 @@ func TestInstallAPIGroups(t *testing.T) { ...@@ -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()
......
...@@ -348,8 +348,10 @@ func (m *Master) InstallAPIs(c *Config) { ...@@ -348,8 +348,10 @@ 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 {
glog.Fatalf("Error in registering group versions: %v", err) if err := m.InstallAPIGroup(&apiGroupsInfo[i]); err != nil {
glog.Fatalf("Error in registering group versions: %v", err)
}
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment