master.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607
  1. /*
  2. Copyright 2014 The Kubernetes Authors.
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. http://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package master
  14. import (
  15. "context"
  16. "fmt"
  17. "net"
  18. "net/http"
  19. "reflect"
  20. "strconv"
  21. "time"
  22. admissionregistrationv1 "k8s.io/api/admissionregistration/v1"
  23. admissionregistrationv1beta1 "k8s.io/api/admissionregistration/v1beta1"
  24. appsv1 "k8s.io/api/apps/v1"
  25. auditregistrationv1alpha1 "k8s.io/api/auditregistration/v1alpha1"
  26. authenticationv1 "k8s.io/api/authentication/v1"
  27. authenticationv1beta1 "k8s.io/api/authentication/v1beta1"
  28. authorizationapiv1 "k8s.io/api/authorization/v1"
  29. authorizationapiv1beta1 "k8s.io/api/authorization/v1beta1"
  30. autoscalingapiv1 "k8s.io/api/autoscaling/v1"
  31. autoscalingapiv2beta1 "k8s.io/api/autoscaling/v2beta1"
  32. autoscalingapiv2beta2 "k8s.io/api/autoscaling/v2beta2"
  33. batchapiv1 "k8s.io/api/batch/v1"
  34. batchapiv1beta1 "k8s.io/api/batch/v1beta1"
  35. batchapiv2alpha1 "k8s.io/api/batch/v2alpha1"
  36. certificatesapiv1beta1 "k8s.io/api/certificates/v1beta1"
  37. coordinationapiv1 "k8s.io/api/coordination/v1"
  38. coordinationapiv1beta1 "k8s.io/api/coordination/v1beta1"
  39. apiv1 "k8s.io/api/core/v1"
  40. discoveryv1beta1 "k8s.io/api/discovery/v1beta1"
  41. eventsv1beta1 "k8s.io/api/events/v1beta1"
  42. extensionsapiv1beta1 "k8s.io/api/extensions/v1beta1"
  43. flowcontrolv1alpha1 "k8s.io/api/flowcontrol/v1alpha1"
  44. networkingapiv1 "k8s.io/api/networking/v1"
  45. networkingapiv1beta1 "k8s.io/api/networking/v1beta1"
  46. nodev1alpha1 "k8s.io/api/node/v1alpha1"
  47. nodev1beta1 "k8s.io/api/node/v1beta1"
  48. policyapiv1beta1 "k8s.io/api/policy/v1beta1"
  49. rbacv1 "k8s.io/api/rbac/v1"
  50. rbacv1alpha1 "k8s.io/api/rbac/v1alpha1"
  51. rbacv1beta1 "k8s.io/api/rbac/v1beta1"
  52. schedulingapiv1 "k8s.io/api/scheduling/v1"
  53. schedulingv1alpha1 "k8s.io/api/scheduling/v1alpha1"
  54. schedulingapiv1beta1 "k8s.io/api/scheduling/v1beta1"
  55. settingsv1alpha1 "k8s.io/api/settings/v1alpha1"
  56. storageapiv1 "k8s.io/api/storage/v1"
  57. storageapiv1alpha1 "k8s.io/api/storage/v1alpha1"
  58. storageapiv1beta1 "k8s.io/api/storage/v1beta1"
  59. metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  60. utilnet "k8s.io/apimachinery/pkg/util/net"
  61. "k8s.io/apimachinery/pkg/util/runtime"
  62. "k8s.io/apiserver/pkg/endpoints/discovery"
  63. "k8s.io/apiserver/pkg/registry/generic"
  64. genericapiserver "k8s.io/apiserver/pkg/server"
  65. "k8s.io/apiserver/pkg/server/dynamiccertificates"
  66. "k8s.io/apiserver/pkg/server/healthz"
  67. serverstorage "k8s.io/apiserver/pkg/server/storage"
  68. storagefactory "k8s.io/apiserver/pkg/storage/storagebackend/factory"
  69. utilfeature "k8s.io/apiserver/pkg/util/feature"
  70. "k8s.io/client-go/informers"
  71. "k8s.io/client-go/kubernetes"
  72. corev1client "k8s.io/client-go/kubernetes/typed/core/v1"
  73. discoveryclient "k8s.io/client-go/kubernetes/typed/discovery/v1beta1"
  74. api "k8s.io/kubernetes/pkg/apis/core"
  75. "k8s.io/kubernetes/pkg/features"
  76. kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options"
  77. kubeletclient "k8s.io/kubernetes/pkg/kubelet/client"
  78. "k8s.io/kubernetes/pkg/master/controller/clusterauthenticationtrust"
  79. "k8s.io/kubernetes/pkg/master/reconcilers"
  80. "k8s.io/kubernetes/pkg/master/tunneler"
  81. "k8s.io/kubernetes/pkg/routes"
  82. "k8s.io/kubernetes/pkg/serviceaccount"
  83. nodeutil "k8s.io/kubernetes/pkg/util/node"
  84. "k8s.io/klog"
  85. // RESTStorage installers
  86. admissionregistrationrest "k8s.io/kubernetes/pkg/registry/admissionregistration/rest"
  87. appsrest "k8s.io/kubernetes/pkg/registry/apps/rest"
  88. auditregistrationrest "k8s.io/kubernetes/pkg/registry/auditregistration/rest"
  89. authenticationrest "k8s.io/kubernetes/pkg/registry/authentication/rest"
  90. authorizationrest "k8s.io/kubernetes/pkg/registry/authorization/rest"
  91. autoscalingrest "k8s.io/kubernetes/pkg/registry/autoscaling/rest"
  92. batchrest "k8s.io/kubernetes/pkg/registry/batch/rest"
  93. certificatesrest "k8s.io/kubernetes/pkg/registry/certificates/rest"
  94. coordinationrest "k8s.io/kubernetes/pkg/registry/coordination/rest"
  95. corerest "k8s.io/kubernetes/pkg/registry/core/rest"
  96. discoveryrest "k8s.io/kubernetes/pkg/registry/discovery/rest"
  97. eventsrest "k8s.io/kubernetes/pkg/registry/events/rest"
  98. extensionsrest "k8s.io/kubernetes/pkg/registry/extensions/rest"
  99. flowcontrolrest "k8s.io/kubernetes/pkg/registry/flowcontrol/rest"
  100. networkingrest "k8s.io/kubernetes/pkg/registry/networking/rest"
  101. noderest "k8s.io/kubernetes/pkg/registry/node/rest"
  102. policyrest "k8s.io/kubernetes/pkg/registry/policy/rest"
  103. rbacrest "k8s.io/kubernetes/pkg/registry/rbac/rest"
  104. schedulingrest "k8s.io/kubernetes/pkg/registry/scheduling/rest"
  105. settingsrest "k8s.io/kubernetes/pkg/registry/settings/rest"
  106. storagerest "k8s.io/kubernetes/pkg/registry/storage/rest"
  107. )
  108. const (
  109. // DefaultEndpointReconcilerInterval is the default amount of time for how often the endpoints for
  110. // the kubernetes Service are reconciled.
  111. DefaultEndpointReconcilerInterval = 10 * time.Second
  112. // DefaultEndpointReconcilerTTL is the default TTL timeout for the storage layer
  113. DefaultEndpointReconcilerTTL = 15 * time.Second
  114. )
  115. // ExtraConfig defines extra configuration for the master
  116. type ExtraConfig struct {
  117. ClusterAuthenticationInfo clusterauthenticationtrust.ClusterAuthenticationInfo
  118. APIResourceConfigSource serverstorage.APIResourceConfigSource
  119. StorageFactory serverstorage.StorageFactory
  120. EndpointReconcilerConfig EndpointReconcilerConfig
  121. EventTTL time.Duration
  122. KubeletClientConfig kubeletclient.KubeletClientConfig
  123. // Used to start and monitor tunneling
  124. Tunneler tunneler.Tunneler
  125. EnableLogsSupport bool
  126. ProxyTransport http.RoundTripper
  127. // Values to build the IP addresses used by discovery
  128. // The range of IPs to be assigned to services with type=ClusterIP or greater
  129. ServiceIPRange net.IPNet
  130. // The IP address for the GenericAPIServer service (must be inside ServiceIPRange)
  131. APIServerServiceIP net.IP
  132. // dual stack services, the range represents an alternative IP range for service IP
  133. // must be of different family than primary (ServiceIPRange)
  134. SecondaryServiceIPRange net.IPNet
  135. // the secondary IP address the GenericAPIServer service (must be inside SecondaryServiceIPRange)
  136. SecondaryAPIServerServiceIP net.IP
  137. // Port for the apiserver service.
  138. APIServerServicePort int
  139. // TODO, we can probably group service related items into a substruct to make it easier to configure
  140. // the API server items and `Extra*` fields likely fit nicely together.
  141. // The range of ports to be assigned to services with type=NodePort or greater
  142. ServiceNodePortRange utilnet.PortRange
  143. // Additional ports to be exposed on the GenericAPIServer service
  144. // extraServicePorts is injectable in the event that more ports
  145. // (other than the default 443/tcp) are exposed on the GenericAPIServer
  146. // and those ports need to be load balanced by the GenericAPIServer
  147. // service because this pkg is linked by out-of-tree projects
  148. // like openshift which want to use the GenericAPIServer but also do
  149. // more stuff.
  150. ExtraServicePorts []apiv1.ServicePort
  151. // Additional ports to be exposed on the GenericAPIServer endpoints
  152. // Port names should align with ports defined in ExtraServicePorts
  153. ExtraEndpointPorts []apiv1.EndpointPort
  154. // If non-zero, the "kubernetes" services uses this port as NodePort.
  155. KubernetesServiceNodePort int
  156. // Number of masters running; all masters must be started with the
  157. // same value for this field. (Numbers > 1 currently untested.)
  158. MasterCount int
  159. // MasterEndpointReconcileTTL sets the time to live in seconds of an
  160. // endpoint record recorded by each master. The endpoints are checked at an
  161. // interval that is 2/3 of this value and this value defaults to 15s if
  162. // unset. In very large clusters, this value may be increased to reduce the
  163. // possibility that the master endpoint record expires (due to other load
  164. // on the etcd server) and causes masters to drop in and out of the
  165. // kubernetes service record. It is not recommended to set this value below
  166. // 15s.
  167. MasterEndpointReconcileTTL time.Duration
  168. // Selects which reconciler to use
  169. EndpointReconcilerType reconcilers.Type
  170. ServiceAccountIssuer serviceaccount.TokenGenerator
  171. ServiceAccountMaxExpiration time.Duration
  172. VersionedInformers informers.SharedInformerFactory
  173. }
  174. // Config defines configuration for the master
  175. type Config struct {
  176. GenericConfig *genericapiserver.Config
  177. ExtraConfig ExtraConfig
  178. }
  179. type completedConfig struct {
  180. GenericConfig genericapiserver.CompletedConfig
  181. ExtraConfig *ExtraConfig
  182. }
  183. // CompletedConfig embeds a private pointer that cannot be instantiated outside of this package
  184. type CompletedConfig struct {
  185. *completedConfig
  186. }
  187. // EndpointReconcilerConfig holds the endpoint reconciler and endpoint reconciliation interval to be
  188. // used by the master.
  189. type EndpointReconcilerConfig struct {
  190. Reconciler reconcilers.EndpointReconciler
  191. Interval time.Duration
  192. }
  193. // Master contains state for a Kubernetes cluster master/api server.
  194. type Master struct {
  195. GenericAPIServer *genericapiserver.GenericAPIServer
  196. ClusterAuthenticationInfo clusterauthenticationtrust.ClusterAuthenticationInfo
  197. }
  198. func (c *Config) createMasterCountReconciler() reconcilers.EndpointReconciler {
  199. endpointClient := corev1client.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig)
  200. var endpointSliceClient discoveryclient.EndpointSlicesGetter
  201. if utilfeature.DefaultFeatureGate.Enabled(features.EndpointSlice) {
  202. endpointSliceClient = discoveryclient.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig)
  203. }
  204. endpointsAdapter := reconcilers.NewEndpointsAdapter(endpointClient, endpointSliceClient)
  205. return reconcilers.NewMasterCountEndpointReconciler(c.ExtraConfig.MasterCount, endpointsAdapter)
  206. }
  207. func (c *Config) createNoneReconciler() reconcilers.EndpointReconciler {
  208. return reconcilers.NewNoneEndpointReconciler()
  209. }
  210. func (c *Config) createLeaseReconciler() reconcilers.EndpointReconciler {
  211. endpointClient := corev1client.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig)
  212. var endpointSliceClient discoveryclient.EndpointSlicesGetter
  213. if utilfeature.DefaultFeatureGate.Enabled(features.EndpointSlice) {
  214. endpointSliceClient = discoveryclient.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig)
  215. }
  216. endpointsAdapter := reconcilers.NewEndpointsAdapter(endpointClient, endpointSliceClient)
  217. ttl := c.ExtraConfig.MasterEndpointReconcileTTL
  218. config, err := c.ExtraConfig.StorageFactory.NewConfig(api.Resource("apiServerIPInfo"))
  219. if err != nil {
  220. klog.Fatalf("Error determining service IP ranges: %v", err)
  221. }
  222. leaseStorage, _, err := storagefactory.Create(*config)
  223. if err != nil {
  224. klog.Fatalf("Error creating storage factory: %v", err)
  225. }
  226. masterLeases := reconcilers.NewLeases(leaseStorage, "/masterleases/", ttl)
  227. return reconcilers.NewLeaseEndpointReconciler(endpointsAdapter, masterLeases)
  228. }
  229. func (c *Config) createEndpointReconciler() reconcilers.EndpointReconciler {
  230. klog.Infof("Using reconciler: %v", c.ExtraConfig.EndpointReconcilerType)
  231. switch c.ExtraConfig.EndpointReconcilerType {
  232. // there are numerous test dependencies that depend on a default controller
  233. case "", reconcilers.MasterCountReconcilerType:
  234. return c.createMasterCountReconciler()
  235. case reconcilers.LeaseEndpointReconcilerType:
  236. return c.createLeaseReconciler()
  237. case reconcilers.NoneEndpointReconcilerType:
  238. return c.createNoneReconciler()
  239. default:
  240. klog.Fatalf("Reconciler not implemented: %v", c.ExtraConfig.EndpointReconcilerType)
  241. }
  242. return nil
  243. }
  244. // Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.
  245. func (c *Config) Complete() CompletedConfig {
  246. cfg := completedConfig{
  247. c.GenericConfig.Complete(c.ExtraConfig.VersionedInformers),
  248. &c.ExtraConfig,
  249. }
  250. serviceIPRange, apiServerServiceIP, err := ServiceIPRange(cfg.ExtraConfig.ServiceIPRange)
  251. if err != nil {
  252. klog.Fatalf("Error determining service IP ranges: %v", err)
  253. }
  254. if cfg.ExtraConfig.ServiceIPRange.IP == nil {
  255. cfg.ExtraConfig.ServiceIPRange = serviceIPRange
  256. }
  257. if cfg.ExtraConfig.APIServerServiceIP == nil {
  258. cfg.ExtraConfig.APIServerServiceIP = apiServerServiceIP
  259. }
  260. discoveryAddresses := discovery.DefaultAddresses{DefaultAddress: cfg.GenericConfig.ExternalAddress}
  261. discoveryAddresses.CIDRRules = append(discoveryAddresses.CIDRRules,
  262. discovery.CIDRRule{IPRange: cfg.ExtraConfig.ServiceIPRange, Address: net.JoinHostPort(cfg.ExtraConfig.APIServerServiceIP.String(), strconv.Itoa(cfg.ExtraConfig.APIServerServicePort))})
  263. cfg.GenericConfig.DiscoveryAddresses = discoveryAddresses
  264. if cfg.ExtraConfig.ServiceNodePortRange.Size == 0 {
  265. // TODO: Currently no way to specify an empty range (do we need to allow this?)
  266. // We should probably allow this for clouds that don't require NodePort to do load-balancing (GCE)
  267. // but then that breaks the strict nestedness of ServiceType.
  268. // Review post-v1
  269. cfg.ExtraConfig.ServiceNodePortRange = kubeoptions.DefaultServiceNodePortRange
  270. klog.Infof("Node port range unspecified. Defaulting to %v.", cfg.ExtraConfig.ServiceNodePortRange)
  271. }
  272. if cfg.ExtraConfig.EndpointReconcilerConfig.Interval == 0 {
  273. cfg.ExtraConfig.EndpointReconcilerConfig.Interval = DefaultEndpointReconcilerInterval
  274. }
  275. if cfg.ExtraConfig.MasterEndpointReconcileTTL == 0 {
  276. cfg.ExtraConfig.MasterEndpointReconcileTTL = DefaultEndpointReconcilerTTL
  277. }
  278. if cfg.ExtraConfig.EndpointReconcilerConfig.Reconciler == nil {
  279. cfg.ExtraConfig.EndpointReconcilerConfig.Reconciler = c.createEndpointReconciler()
  280. }
  281. return CompletedConfig{&cfg}
  282. }
  283. // New returns a new instance of Master from the given config.
  284. // Certain config fields will be set to a default value if unset.
  285. // Certain config fields must be specified, including:
  286. // KubeletClientConfig
  287. func (c completedConfig) New(delegationTarget genericapiserver.DelegationTarget) (*Master, error) {
  288. if reflect.DeepEqual(c.ExtraConfig.KubeletClientConfig, kubeletclient.KubeletClientConfig{}) {
  289. return nil, fmt.Errorf("Master.New() called with empty config.KubeletClientConfig")
  290. }
  291. s, err := c.GenericConfig.New("kube-apiserver", delegationTarget)
  292. if err != nil {
  293. return nil, err
  294. }
  295. if c.ExtraConfig.EnableLogsSupport {
  296. routes.Logs{}.Install(s.Handler.GoRestfulContainer)
  297. }
  298. m := &Master{
  299. GenericAPIServer: s,
  300. ClusterAuthenticationInfo: c.ExtraConfig.ClusterAuthenticationInfo,
  301. }
  302. // install legacy rest storage
  303. if c.ExtraConfig.APIResourceConfigSource.VersionEnabled(apiv1.SchemeGroupVersion) {
  304. legacyRESTStorageProvider := corerest.LegacyRESTStorageProvider{
  305. StorageFactory: c.ExtraConfig.StorageFactory,
  306. ProxyTransport: c.ExtraConfig.ProxyTransport,
  307. KubeletClientConfig: c.ExtraConfig.KubeletClientConfig,
  308. EventTTL: c.ExtraConfig.EventTTL,
  309. ServiceIPRange: c.ExtraConfig.ServiceIPRange,
  310. SecondaryServiceIPRange: c.ExtraConfig.SecondaryServiceIPRange,
  311. ServiceNodePortRange: c.ExtraConfig.ServiceNodePortRange,
  312. LoopbackClientConfig: c.GenericConfig.LoopbackClientConfig,
  313. ServiceAccountIssuer: c.ExtraConfig.ServiceAccountIssuer,
  314. ServiceAccountMaxExpiration: c.ExtraConfig.ServiceAccountMaxExpiration,
  315. APIAudiences: c.GenericConfig.Authentication.APIAudiences,
  316. }
  317. if err := m.InstallLegacyAPI(&c, c.GenericConfig.RESTOptionsGetter, legacyRESTStorageProvider); err != nil {
  318. return nil, err
  319. }
  320. }
  321. // The order here is preserved in discovery.
  322. // If resources with identical names exist in more than one of these groups (e.g. "deployments.apps"" and "deployments.extensions"),
  323. // the order of this list determines which group an unqualified resource name (e.g. "deployments") should prefer.
  324. // This priority order is used for local discovery, but it ends up aggregated in `k8s.io/kubernetes/cmd/kube-apiserver/app/aggregator.go
  325. // with specific priorities.
  326. // TODO: describe the priority all the way down in the RESTStorageProviders and plumb it back through the various discovery
  327. // handlers that we have.
  328. restStorageProviders := []RESTStorageProvider{
  329. auditregistrationrest.RESTStorageProvider{},
  330. authenticationrest.RESTStorageProvider{Authenticator: c.GenericConfig.Authentication.Authenticator, APIAudiences: c.GenericConfig.Authentication.APIAudiences},
  331. authorizationrest.RESTStorageProvider{Authorizer: c.GenericConfig.Authorization.Authorizer, RuleResolver: c.GenericConfig.RuleResolver},
  332. autoscalingrest.RESTStorageProvider{},
  333. batchrest.RESTStorageProvider{},
  334. certificatesrest.RESTStorageProvider{},
  335. coordinationrest.RESTStorageProvider{},
  336. discoveryrest.StorageProvider{},
  337. extensionsrest.RESTStorageProvider{},
  338. networkingrest.RESTStorageProvider{},
  339. noderest.RESTStorageProvider{},
  340. policyrest.RESTStorageProvider{},
  341. rbacrest.RESTStorageProvider{Authorizer: c.GenericConfig.Authorization.Authorizer},
  342. schedulingrest.RESTStorageProvider{},
  343. settingsrest.RESTStorageProvider{},
  344. storagerest.RESTStorageProvider{},
  345. flowcontrolrest.RESTStorageProvider{},
  346. // keep apps after extensions so legacy clients resolve the extensions versions of shared resource names.
  347. // See https://github.com/kubernetes/kubernetes/issues/42392
  348. appsrest.RESTStorageProvider{},
  349. admissionregistrationrest.RESTStorageProvider{},
  350. eventsrest.RESTStorageProvider{TTL: c.ExtraConfig.EventTTL},
  351. }
  352. if err := m.InstallAPIs(c.ExtraConfig.APIResourceConfigSource, c.GenericConfig.RESTOptionsGetter, restStorageProviders...); err != nil {
  353. return nil, err
  354. }
  355. if c.ExtraConfig.Tunneler != nil {
  356. m.installTunneler(c.ExtraConfig.Tunneler, corev1client.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig).Nodes())
  357. }
  358. m.GenericAPIServer.AddPostStartHookOrDie("start-cluster-authentication-info-controller", func(hookContext genericapiserver.PostStartHookContext) error {
  359. kubeClient, err := kubernetes.NewForConfig(hookContext.LoopbackClientConfig)
  360. if err != nil {
  361. return err
  362. }
  363. controller := clusterauthenticationtrust.NewClusterAuthenticationTrustController(m.ClusterAuthenticationInfo, kubeClient)
  364. // prime values and start listeners
  365. if m.ClusterAuthenticationInfo.ClientCA != nil {
  366. if notifier, ok := m.ClusterAuthenticationInfo.ClientCA.(dynamiccertificates.Notifier); ok {
  367. notifier.AddListener(controller)
  368. }
  369. if controller, ok := m.ClusterAuthenticationInfo.ClientCA.(dynamiccertificates.ControllerRunner); ok {
  370. // runonce to be sure that we have a value.
  371. if err := controller.RunOnce(); err != nil {
  372. runtime.HandleError(err)
  373. }
  374. go controller.Run(1, hookContext.StopCh)
  375. }
  376. }
  377. if m.ClusterAuthenticationInfo.RequestHeaderCA != nil {
  378. if notifier, ok := m.ClusterAuthenticationInfo.RequestHeaderCA.(dynamiccertificates.Notifier); ok {
  379. notifier.AddListener(controller)
  380. }
  381. if controller, ok := m.ClusterAuthenticationInfo.RequestHeaderCA.(dynamiccertificates.ControllerRunner); ok {
  382. // runonce to be sure that we have a value.
  383. if err := controller.RunOnce(); err != nil {
  384. runtime.HandleError(err)
  385. }
  386. go controller.Run(1, hookContext.StopCh)
  387. }
  388. }
  389. go controller.Run(1, hookContext.StopCh)
  390. return nil
  391. })
  392. return m, nil
  393. }
  394. // InstallLegacyAPI will install the legacy APIs for the restStorageProviders if they are enabled.
  395. func (m *Master) InstallLegacyAPI(c *completedConfig, restOptionsGetter generic.RESTOptionsGetter, legacyRESTStorageProvider corerest.LegacyRESTStorageProvider) error {
  396. legacyRESTStorage, apiGroupInfo, err := legacyRESTStorageProvider.NewLegacyRESTStorage(restOptionsGetter)
  397. if err != nil {
  398. return fmt.Errorf("error building core storage: %v", err)
  399. }
  400. controllerName := "bootstrap-controller"
  401. coreClient := corev1client.NewForConfigOrDie(c.GenericConfig.LoopbackClientConfig)
  402. bootstrapController := c.NewBootstrapController(legacyRESTStorage, coreClient, coreClient, coreClient, coreClient.RESTClient())
  403. m.GenericAPIServer.AddPostStartHookOrDie(controllerName, bootstrapController.PostStartHook)
  404. m.GenericAPIServer.AddPreShutdownHookOrDie(controllerName, bootstrapController.PreShutdownHook)
  405. if err := m.GenericAPIServer.InstallLegacyAPIGroup(genericapiserver.DefaultLegacyAPIPrefix, &apiGroupInfo); err != nil {
  406. return fmt.Errorf("error in registering group versions: %v", err)
  407. }
  408. return nil
  409. }
  410. func (m *Master) installTunneler(nodeTunneler tunneler.Tunneler, nodeClient corev1client.NodeInterface) {
  411. nodeTunneler.Run(nodeAddressProvider{nodeClient}.externalAddresses)
  412. err := m.GenericAPIServer.AddHealthChecks(healthz.NamedCheck("SSH Tunnel Check", tunneler.TunnelSyncHealthChecker(nodeTunneler)))
  413. if err != nil {
  414. klog.Errorf("Failed adding ssh tunnel health check %v\n", err)
  415. }
  416. }
  417. // RESTStorageProvider is a factory type for REST storage.
  418. type RESTStorageProvider interface {
  419. GroupName() string
  420. NewRESTStorage(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter) (genericapiserver.APIGroupInfo, bool, error)
  421. }
  422. // InstallAPIs will install the APIs for the restStorageProviders if they are enabled.
  423. func (m *Master) InstallAPIs(apiResourceConfigSource serverstorage.APIResourceConfigSource, restOptionsGetter generic.RESTOptionsGetter, restStorageProviders ...RESTStorageProvider) error {
  424. apiGroupsInfo := []*genericapiserver.APIGroupInfo{}
  425. for _, restStorageBuilder := range restStorageProviders {
  426. groupName := restStorageBuilder.GroupName()
  427. if !apiResourceConfigSource.AnyVersionForGroupEnabled(groupName) {
  428. klog.V(1).Infof("Skipping disabled API group %q.", groupName)
  429. continue
  430. }
  431. apiGroupInfo, enabled, err := restStorageBuilder.NewRESTStorage(apiResourceConfigSource, restOptionsGetter)
  432. if err != nil {
  433. return fmt.Errorf("problem initializing API group %q : %v", groupName, err)
  434. }
  435. if !enabled {
  436. klog.Warningf("API group %q is not enabled, skipping.", groupName)
  437. continue
  438. }
  439. klog.V(1).Infof("Enabling API group %q.", groupName)
  440. if postHookProvider, ok := restStorageBuilder.(genericapiserver.PostStartHookProvider); ok {
  441. name, hook, err := postHookProvider.PostStartHook()
  442. if err != nil {
  443. klog.Fatalf("Error building PostStartHook: %v", err)
  444. }
  445. m.GenericAPIServer.AddPostStartHookOrDie(name, hook)
  446. }
  447. apiGroupsInfo = append(apiGroupsInfo, &apiGroupInfo)
  448. }
  449. if err := m.GenericAPIServer.InstallAPIGroups(apiGroupsInfo...); err != nil {
  450. return fmt.Errorf("error in registering group versions: %v", err)
  451. }
  452. return nil
  453. }
  454. type nodeAddressProvider struct {
  455. nodeClient corev1client.NodeInterface
  456. }
  457. func (n nodeAddressProvider) externalAddresses() ([]string, error) {
  458. preferredAddressTypes := []apiv1.NodeAddressType{
  459. apiv1.NodeExternalIP,
  460. }
  461. nodes, err := n.nodeClient.List(context.TODO(), metav1.ListOptions{})
  462. if err != nil {
  463. return nil, err
  464. }
  465. var matchErr error
  466. addrs := []string{}
  467. for ix := range nodes.Items {
  468. node := &nodes.Items[ix]
  469. addr, err := nodeutil.GetPreferredNodeAddress(node, preferredAddressTypes)
  470. if err != nil {
  471. if _, ok := err.(*nodeutil.NoMatchError); ok {
  472. matchErr = err
  473. continue
  474. }
  475. return nil, err
  476. }
  477. addrs = append(addrs, addr)
  478. }
  479. if len(addrs) == 0 && matchErr != nil {
  480. // We only return an error if we have items.
  481. // Currently we return empty list/no error if Items is empty.
  482. // We do this for backward compatibility reasons.
  483. return nil, matchErr
  484. }
  485. return addrs, nil
  486. }
  487. // DefaultAPIResourceConfigSource returns default configuration for an APIResource.
  488. func DefaultAPIResourceConfigSource() *serverstorage.ResourceConfig {
  489. ret := serverstorage.NewResourceConfig()
  490. // NOTE: GroupVersions listed here will be enabled by default. Don't put alpha versions in the list.
  491. ret.EnableVersions(
  492. admissionregistrationv1.SchemeGroupVersion,
  493. admissionregistrationv1beta1.SchemeGroupVersion,
  494. apiv1.SchemeGroupVersion,
  495. appsv1.SchemeGroupVersion,
  496. authenticationv1.SchemeGroupVersion,
  497. authenticationv1beta1.SchemeGroupVersion,
  498. authorizationapiv1.SchemeGroupVersion,
  499. authorizationapiv1beta1.SchemeGroupVersion,
  500. autoscalingapiv1.SchemeGroupVersion,
  501. autoscalingapiv2beta1.SchemeGroupVersion,
  502. autoscalingapiv2beta2.SchemeGroupVersion,
  503. batchapiv1.SchemeGroupVersion,
  504. batchapiv1beta1.SchemeGroupVersion,
  505. certificatesapiv1beta1.SchemeGroupVersion,
  506. coordinationapiv1.SchemeGroupVersion,
  507. coordinationapiv1beta1.SchemeGroupVersion,
  508. discoveryv1beta1.SchemeGroupVersion,
  509. eventsv1beta1.SchemeGroupVersion,
  510. extensionsapiv1beta1.SchemeGroupVersion,
  511. networkingapiv1.SchemeGroupVersion,
  512. networkingapiv1beta1.SchemeGroupVersion,
  513. nodev1beta1.SchemeGroupVersion,
  514. policyapiv1beta1.SchemeGroupVersion,
  515. rbacv1.SchemeGroupVersion,
  516. rbacv1beta1.SchemeGroupVersion,
  517. storageapiv1.SchemeGroupVersion,
  518. storageapiv1beta1.SchemeGroupVersion,
  519. schedulingapiv1beta1.SchemeGroupVersion,
  520. schedulingapiv1.SchemeGroupVersion,
  521. )
  522. // enable non-deprecated beta resources in extensions/v1beta1 explicitly so we have a full list of what's possible to serve
  523. ret.EnableResources(
  524. extensionsapiv1beta1.SchemeGroupVersion.WithResource("ingresses"),
  525. )
  526. // disable alpha versions explicitly so we have a full list of what's possible to serve
  527. ret.DisableVersions(
  528. auditregistrationv1alpha1.SchemeGroupVersion,
  529. batchapiv2alpha1.SchemeGroupVersion,
  530. nodev1alpha1.SchemeGroupVersion,
  531. rbacv1alpha1.SchemeGroupVersion,
  532. schedulingv1alpha1.SchemeGroupVersion,
  533. settingsv1alpha1.SchemeGroupVersion,
  534. storageapiv1alpha1.SchemeGroupVersion,
  535. flowcontrolv1alpha1.SchemeGroupVersion,
  536. )
  537. return ret
  538. }