github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 12:15:52 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #106872 from calvin0327/fix-kubeadm-kubelet-constant

Browse Source 
kubeadm: amend constant to kubelet.
This commit is contained in:
Kubernetes Prow Robot 2021-12-09 16:29:22 -08:00 committed by GitHub
commit 481459d12d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cmd/kubeadm/app/phases/kubelet/kubelet.go
View File

@ -19,6 +19,7 @@ package kubelet
import ( import (
"fmt" "fmt"
kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
"k8s.io/kubernetes/cmd/kubeadm/app/util/initsystem" "k8s.io/kubernetes/cmd/kubeadm/app/util/initsystem"
) )
@ -31,12 +32,12 @@ func TryStartKubelet() {
return return
} }
if !initSystem.ServiceExists("kubelet") { if !initSystem.ServiceExists(kubeadmconstants.Kubelet) {
fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet is running properly.") fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet is running properly.")
} }
// This runs "systemctl daemon-reload && systemctl restart kubelet" // This runs "systemctl daemon-reload && systemctl restart kubelet"
if err := initSystem.ServiceRestart("kubelet"); err != nil { if err := initSystem.ServiceRestart(kubeadmconstants.Kubelet); err != nil {
fmt.Printf("[kubelet-start] WARNING: unable to start the kubelet service: [%v]\n", err) fmt.Printf("[kubelet-start] WARNING: unable to start the kubelet service: [%v]\n", err)
fmt.Printf("[kubelet-start] Please ensure kubelet is reloaded and running manually.\n") fmt.Printf("[kubelet-start] Please ensure kubelet is reloaded and running manually.\n")
} }
@ -51,12 +52,12 @@ func TryStopKubelet() {
return return
} }
if !initSystem.ServiceExists("kubelet") { if !initSystem.ServiceExists(kubeadmconstants.Kubelet) {
fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet not running for a short period of time while setting up configuration for it.") fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet not running for a short period of time while setting up configuration for it.")
} }
// This runs "systemctl daemon-reload && systemctl stop kubelet" // This runs "systemctl daemon-reload && systemctl stop kubelet"
if err := initSystem.ServiceStop("kubelet"); err != nil { if err := initSystem.ServiceStop(kubeadmconstants.Kubelet); err != nil {
fmt.Printf("[kubelet-start] WARNING: unable to stop the kubelet service momentarily: [%v]\n", err) fmt.Printf("[kubelet-start] WARNING: unable to stop the kubelet service momentarily: [%v]\n", err)
} }
} }
@ -70,12 +71,12 @@ func TryRestartKubelet() {
return return
} }
if !initSystem.ServiceExists("kubelet") { if !initSystem.ServiceExists(kubeadmconstants.Kubelet) {
fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet not running for a short period of time while setting up configuration for it.") fmt.Println("[kubelet-start] couldn't detect a kubelet service, can't make sure the kubelet not running for a short period of time while setting up configuration for it.")
} }
// This runs "systemctl daemon-reload && systemctl stop kubelet" // This runs "systemctl daemon-reload && systemctl stop kubelet"
if err := initSystem.ServiceRestart("kubelet"); err != nil { if err := initSystem.ServiceRestart(kubeadmconstants.Kubelet); err != nil {
fmt.Printf("[kubelet-start] WARNING: unable to restart the kubelet service momentarily: [%v]\n", err) fmt.Printf("[kubelet-start] WARNING: unable to restart the kubelet service momentarily: [%v]\n", err)
} }
} }