diff --git a/cmd/kubeadm/app/cmd/BUILD b/cmd/kubeadm/app/cmd/BUILD index 3603c31e1b5..fba65c86023 100644 --- a/cmd/kubeadm/app/cmd/BUILD +++ b/cmd/kubeadm/app/cmd/BUILD @@ -29,6 +29,7 @@ go_library( "//cmd/kubeadm/app/discovery:go_default_library", "//cmd/kubeadm/app/features:go_default_library", "//cmd/kubeadm/app/images:go_default_library", + "//cmd/kubeadm/app/node:go_default_library", "//cmd/kubeadm/app/phases/addons/dns:go_default_library", "//cmd/kubeadm/app/phases/addons/proxy:go_default_library", "//cmd/kubeadm/app/phases/apiconfig:go_default_library", diff --git a/cmd/kubeadm/app/cmd/join.go b/cmd/kubeadm/app/cmd/join.go index acc8a094070..3de2b6d45ce 100644 --- a/cmd/kubeadm/app/cmd/join.go +++ b/cmd/kubeadm/app/cmd/join.go @@ -32,6 +32,7 @@ import ( "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm/validation" kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants" "k8s.io/kubernetes/cmd/kubeadm/app/discovery" + kubeadmnode "k8s.io/kubernetes/cmd/kubeadm/app/node" "k8s.io/kubernetes/cmd/kubeadm/app/preflight" kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util" kubeconfigutil "k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig" @@ -203,7 +204,20 @@ func (j *Join) Run(out io.Writer) error { return err } - kubeconfigFile := filepath.Join(kubeadmconstants.KubernetesDir, kubeadmconstants.KubeletBootstrapKubeConfigFileName) + hostname := nodeutil.GetHostname(j.cfg.NodeName) + + client, err := kubeconfigutil.KubeConfigToClientSet(cfg) + if err != nil { + return err + } + if err := kubeadmnode.ValidateAPIServer(client); err != nil { + return err + } + if err := kubeadmnode.PerformTLSBootstrap(cfg, hostname); err != nil { + return err + } + + kubeconfigFile := filepath.Join(kubeadmconstants.KubernetesDir, kubeadmconstants.KubeletKubeConfigFileName) if err := kubeconfigutil.WriteToDisk(kubeconfigFile, cfg); err != nil { return err } diff --git a/cmd/kubeadm/app/node/BUILD b/cmd/kubeadm/app/node/BUILD index b06613c6bd4..001da272bc1 100644 --- a/cmd/kubeadm/app/node/BUILD +++ b/cmd/kubeadm/app/node/BUILD @@ -8,10 +8,18 @@ load( go_library( name = "go_default_library", - srcs = ["validate.go"], + srcs = [ + "csr.go", + "validate.go", + ], deps = [ + "//cmd/kubeadm/app/util/kubeconfig:go_default_library", + "//pkg/kubelet/util/csr:go_default_library", "//vendor/k8s.io/api/certificates/v1beta1:go_default_library", + "//vendor/k8s.io/apimachinery/pkg/types:go_default_library", "//vendor/k8s.io/client-go/kubernetes:go_default_library", + "//vendor/k8s.io/client-go/tools/clientcmd/api:go_default_library", + "//vendor/k8s.io/client-go/util/cert:go_default_library", ], ) diff --git a/cmd/kubeadm/app/node/csr.go b/cmd/kubeadm/app/node/csr.go new file mode 100644 index 00000000000..2f4f2b44d61 --- /dev/null +++ b/cmd/kubeadm/app/node/csr.go @@ -0,0 +1,61 @@ +/* +Copyright 2016 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package node + +import ( + "fmt" + + "k8s.io/apimachinery/pkg/types" + clientcmdapi "k8s.io/client-go/tools/clientcmd/api" + certutil "k8s.io/client-go/util/cert" + kubeconfigutil "k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig" + "k8s.io/kubernetes/pkg/kubelet/util/csr" +) + +const CSRContextAndUser = "kubelet-csr" + +// PerformTLSBootstrap executes a node certificate signing request. +func PerformTLSBootstrap(cfg *clientcmdapi.Config, hostName string) error { + client, err := kubeconfigutil.KubeConfigToClientSet(cfg) + if err != nil { + return err + } + + fmt.Println("[csr] Created API client to obtain unique certificate for this node, generating keys and certificate signing request") + + key, err := certutil.MakeEllipticPrivateKeyPEM() + if err != nil { + return fmt.Errorf("failed to generate private key [%v]", err) + } + + cert, err := csr.RequestNodeCertificate(client.CertificatesV1beta1().CertificateSigningRequests(), key, types.NodeName(hostName)) + if err != nil { + return fmt.Errorf("failed to request signed certificate from the API server [%v]", err) + } + fmt.Println("[csr] Received signed certificate from the API server, generating KubeConfig...") + + cfg.AuthInfos[CSRContextAndUser] = &clientcmdapi.AuthInfo{ + ClientKeyData: key, + ClientCertificateData: cert, + } + cfg.Contexts[CSRContextAndUser] = &clientcmdapi.Context{ + AuthInfo: CSRContextAndUser, + Cluster: cfg.Contexts[cfg.CurrentContext].Cluster, + } + cfg.CurrentContext = CSRContextAndUser + return nil +} diff --git a/hack/.golint_failures b/hack/.golint_failures index 0b1c10647ae..47a375eac2e 100644 --- a/hack/.golint_failures +++ b/hack/.golint_failures @@ -17,6 +17,7 @@ cmd/kubeadm/app/discovery cmd/kubeadm/app/discovery/file cmd/kubeadm/app/discovery/token cmd/kubeadm/app/images +cmd/kubeadm/app/node cmd/kubeadm/app/phases/certs/pkiutil cmd/kubeadm/app/preflight cmd/kubeadm/app/util