package kubelet

import "k8s.io/kubernetes/cmd/kubeadm/app/phases/kubelet"

Index ¶

• func CreateConfigMap(cfg *kubeadmapi.ClusterConfiguration, client clientset.Interface) error
• func DownloadConfig(client clientset.Interface, kubeletVersionStr string, kubeletDir string) error
• func GetNodeNameAndHostname(cfg *kubeadmapi.NodeRegistrationOptions) (string, string, error)
• func TryRestartKubelet()
• func TryStartKubelet()
• func TryStopKubelet()
• func WriteConfigToDisk(cfg *kubeadmapi.ClusterConfiguration, kubeletDir string) error
• func WriteKubeletDynamicEnvFile(cfg *kubeadmapi.ClusterConfiguration, nodeReg *kubeadmapi.NodeRegistrationOptions, registerTaintsUsingFlags bool, kubeletDir string) error

Functions ¶

func CreateConfigMap ¶

func CreateConfigMap(cfg *kubeadmapi.ClusterConfiguration, client clientset.Interface) error

CreateConfigMap creates a ConfigMap with the generic kubelet configuration. Used at "kubeadm init" and "kubeadm upgrade" time

func DownloadConfig ¶

func DownloadConfig(client clientset.Interface, kubeletVersionStr string, kubeletDir string) error

DownloadConfig downloads the kubelet configuration from a ConfigMap and writes it to disk. DEPRECATED: Do not use in new code!

func GetNodeNameAndHostname ¶

func GetNodeNameAndHostname(cfg *kubeadmapi.NodeRegistrationOptions) (string, string, error)

GetNodeNameAndHostname obtains the name for this Node using the following precedence (from lower to higher): - actual hostname - NodeRegistrationOptions.Name (same as "--node-name" passed to "kubeadm init/join") - "hostname-overide" flag in NodeRegistrationOptions.KubeletExtraArgs It also returns the hostname or an error if getting the hostname failed.

func TryRestartKubelet ¶

func TryRestartKubelet()

TryRestartKubelet attempts to restart the kubelet service

func TryStartKubelet ¶

func TryStartKubelet()

TryStartKubelet attempts to bring up kubelet service

func TryStopKubelet ¶

func TryStopKubelet()

TryStopKubelet attempts to bring down the kubelet service momentarily

func WriteConfigToDisk ¶

func WriteConfigToDisk(cfg *kubeadmapi.ClusterConfiguration, kubeletDir string) error

WriteConfigToDisk writes the kubelet config object down to a file Used at "kubeadm init" and "kubeadm upgrade" time

func WriteKubeletDynamicEnvFile ¶

func WriteKubeletDynamicEnvFile(cfg *kubeadmapi.ClusterConfiguration, nodeReg *kubeadmapi.NodeRegistrationOptions, registerTaintsUsingFlags bool, kubeletDir string) error

WriteKubeletDynamicEnvFile writes an environment file with dynamic flags to the kubelet. Used at "kubeadm init" and "kubeadm join" time.

Source Files ¶

config.go flags.go kubelet.go