nodes

Documentation

Index

• Constants
• func BootstrapControlPlaneNode(allNodes []config.Node) (*config.Node, error)
• func Command(command string, args ...string) exec.Cmd
• func ConfigNodeAddressAndRole(cluster *ecsv1.KubernetesCluster) (string, ecsv1.NodeRole)
• func ConstructImage(cluster *ecsv1.KubernetesCluster) string
• func CopyFrom(sourcePath string, destPath string) error
• func CopyTo(sourcePath string, destPath string) error
• func KubeConfigPath(clusterName string) string
• func WaitForReady(until time.Time) bool
• func WriteFile(dest, content string) error

Constants

const (
	// KubeletServicePath is systemd service path
	KubeletServicePath = "/usr/lib/systemd/system/kubelet.service"

	KubeletServiceConfigDir     = "/usr/lib/systemd/system/kubelet.service.d/"
	KubeletServicrDefaultConfig = "/etc/sysconfig/kubelet"
)

const Kubeadm10conf = `` /* 898-byte string literal not displayed */

https://github.com/kubernetes/kubernetes/blob/ba8fcafaf8c502a454acd86b728c857932555315/build/debs/10-kubeadm.conf

const KubeletServiceContents = `` /* 312-byte string literal not displayed */

slightly modified from https://github.com/kubernetes/kubernetes/blob/ba8fcafaf8c502a454acd86b728c857932555315/build/debs/kubelet.service

Functions

func BootstrapControlPlaneNode

func BootstrapControlPlaneNode(allNodes []config.Node) (*config.Node, error)

BootstrapControlPlaneNode returns a handle to the bootstrap control plane node

func Command

func Command(command string, args ...string) exec.Cmd

Command returns a new exec.Cmd that will run on the node

func ConfigNodeAddressAndRole

func ConfigNodeAddressAndRole(cluster *ecsv1.KubernetesCluster) (string, ecsv1.NodeRole)

ConfigNodeAddressAndRole is return the host ip and role,get host ip and role from kubernetes cluster

func ConstructImage

func ConstructImage(cluster *ecsv1.KubernetesCluster) string

ConstructImage is return the node image,image representative kubernetes version and contain kubelet, kubectl,kubeadm binary defaule image is registry.cn-hangzhou.aliyuncs.com/aliyun_kube_system/kubernetes:v1.xxx

func CopyFrom

func CopyFrom(sourcePath string, destPath string) error

use grpc copy file

func CopyTo

func CopyTo(sourcePath string, destPath string) error

func KubeConfigPath

func KubeConfigPath(clusterName string) string

KubeConfigPath returns the path to where the Kubeconfig would be placed

func WaitForReady

func WaitForReady(until time.Time) bool

control plane nodes are "Ready".

func WriteFile

func WriteFile(dest, content string) error

WriteFile writes content to dest on the node