github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 09:22:44 +00:00
Code Issues Projects Releases Wiki Activity

Moving InstallSwaggerAPI to Run

Browse Source
This commit is contained in:
nikhiljindal 2016-03-28 14:03:42 -07:00
parent e01feae75a
commit eeeaa6867a
2 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/genericapiserver/genericapiserver.go
View File

@ -616,16 +616,13 @@ func (s *GenericAPIServer) init(c *Config) {
s.installGroupsDiscoveryHandler() s.installGroupsDiscoveryHandler()
} }
// Exposes the given group versions in API. // Exposes the given group versions in API. Helper method to install multiple group versions at once.
func (s *GenericAPIServer) InstallAPIGroups(groupsInfo []APIGroupInfo) error { func (s *GenericAPIServer) InstallAPIGroups(groupsInfo []APIGroupInfo) error {
for _, apiGroupInfo := range groupsInfo { for _, apiGroupInfo := range groupsInfo {
if err := s.installAPIGroup(&apiGroupInfo); err != nil { if err := s.InstallAPIGroup(&apiGroupInfo); err != nil {
return err return err
} }
} }
if s.enableSwaggerSupport {
s.InstallSwaggerAPI()
}
return nil return nil
} }
@ -652,7 +649,10 @@ func (s *GenericAPIServer) installGroupsDiscoveryHandler() {
} }
func (s *GenericAPIServer) Run(options *ServerRunOptions) { func (s *GenericAPIServer) Run(options *ServerRunOptions) {
// We serve on 2 ports. See docs/accessing_the_api.md if s.enableSwaggerSupport {
s.InstallSwaggerAPI()
}
// We serve on 2 ports. See docs/accessing_the_api.md
secureLocation := "" secureLocation := ""
if options.SecurePort != 0 { if options.SecurePort != 0 {
secureLocation = net.JoinHostPort(options.BindAddress.String(), strconv.Itoa(options.SecurePort)) secureLocation = net.JoinHostPort(options.BindAddress.String(), strconv.Itoa(options.SecurePort))
@ -768,7 +768,8 @@ func shouldGenSelfSignedCerts(certPath, keyPath string) bool {
return true return true
} }
func (s *GenericAPIServer) installAPIGroup(apiGroupInfo *APIGroupInfo) error { // Exposes the given group version in API.
func (s *GenericAPIServer) InstallAPIGroup(apiGroupInfo *APIGroupInfo) error {
apiPrefix := s.APIGroupPrefix apiPrefix := s.APIGroupPrefix
if apiGroupInfo.IsLegacyGroup { if apiGroupInfo.IsLegacyGroup {
apiPrefix = s.APIPrefix apiPrefix = s.APIPrefix

2
test/integration/kubectl_test.go
View File

@ -46,6 +46,8 @@ func TestKubectlValidation(t *testing.T) {
defer components.Stop(true, true) defer components.Stop(true, true)
ctx := clientcmdapi.NewContext() ctx := clientcmdapi.NewContext()
cfg := clientcmdapi.NewConfig() cfg := clientcmdapi.NewConfig()
// Enable swagger api on master.
components.KubeMaster.InstallSwaggerAPI()
cluster := clientcmdapi.NewCluster() cluster := clientcmdapi.NewCluster()
cluster.Server = components.ApiServer.URL cluster.Server = components.ApiServer.URL
cluster.InsecureSkipTLSVerify = true cluster.InsecureSkipTLSVerify = true