kubernetes

Documentation

Index

• Constants
• Variables
• func CheckAndInstallKubelet(kubernetesResourceServer, clusterVersion string) error
• func GetKubernetesVersionFromCluster(client kubernetes.Interface) (string, error)
• func RunJobAndCleanup(cliSet *kubernetes.Clientset, job *batchv1.Job, timeout, period time.Duration, ...) error
• func SetKubeletCaCert(config *clientcmdapi.Config) error
• func SetKubeletConfigForNode() error
• func SetKubeletService() error
• func SetKubeletUnitConfig() error

Constants

const (
	// DisableNodeControllerJobNameBase is the prefix of the DisableNodeControllerJob name
	DisableNodeControllerJobNameBase = "yurtctl-disable-node-controller"
)

Variables

var (
	// PropagationPolicy defines the propagation policy used when deleting a resource
	PropagationPolicy = metav1.DeletePropagationBackground

	ErrClusterVersionEmpty = errors.New("cluster version should not be empty")
)

Functions

func CheckAndInstallKubelet

func CheckAndInstallKubelet(kubernetesResourceServer, clusterVersion string) error

CheckAndInstallKubelet install kubelet and kubernetes-cni, skip install if they exist.

func GetKubernetesVersionFromCluster

func GetKubernetesVersionFromCluster(client kubernetes.Interface) (string, error)

GetKubernetesVersionFromCluster get kubernetes cluster version from master.

func RunJobAndCleanup

func RunJobAndCleanup(cliSet *kubernetes.Clientset, job *batchv1.Job, timeout, period time.Duration, waitForTimeout bool) error

RunJobAndCleanup runs the job, wait for it to be complete, and delete it

func SetKubeletCaCert

func SetKubeletCaCert(config *clientcmdapi.Config) error

SetKubeletCaCert write ca.crt for join node.

func SetKubeletConfigForNode

func SetKubeletConfigForNode() error

SetKubeletConfigForNode write kubelet.conf for join node.

func SetKubeletService

func SetKubeletService() error

SetKubeletService configure kubelet service.

func SetKubeletUnitConfig

func SetKubeletUnitConfig() error

SetKubeletUnitConfig configure kubelet startup parameters.