cluster

Documentation

Index

• Variables
• func GenerateKubeadmToken() string
• func GetClusterToken(client ssh.Interface) (string, error)
• func GetClusterTokenWithoutRetry(client ssh.Interface) (string, error)
• func GetNodeCIDRMaskSize(maxNodePodNum int) int
• func LoadAvailableHost(cluster *model.Cluster) (string, error)
• func LoadConnConf(cluster *model.Cluster, availableHost string) (*rest.Config, error)
• func NewClusterClient(cluster *model.Cluster) (*kubernetes.Clientset, error)
• func NewClusterExtensionClient(cluster *model.Cluster) (*extensionClientSet.Clientset, error)
• func PauseConfigApi(conf *string) (*api.Config, error)
• func SelectAliveHost(hosts []string) (string, error)

Variables

var MaxNodePodNumMap = map[int]int{
	24: 110,
	25: 64,
	26: 32,
	27: 16,
}

Functions

func GenerateKubeadmToken

func GenerateKubeadmToken() string

func GetClusterToken

func GetClusterToken(client ssh.Interface) (string, error)

func GetClusterTokenWithoutRetry

func GetClusterTokenWithoutRetry(client ssh.Interface) (string, error)

func GetNodeCIDRMaskSize

func GetNodeCIDRMaskSize(maxNodePodNum int) int

func LoadAvailableHost

func LoadAvailableHost(cluster *model.Cluster) (string, error)

func LoadConnConf

func LoadConnConf(cluster *model.Cluster, availableHost string) (*rest.Config, error)

func NewClusterClient

func NewClusterClient(cluster *model.Cluster) (*kubernetes.Clientset, error)

func NewClusterExtensionClient

func NewClusterExtensionClient(cluster *model.Cluster) (*extensionClientSet.Clientset, error)

func PauseConfigApi

func PauseConfigApi(conf *string) (*api.Config, error)

func SelectAliveHost

func SelectAliveHost(hosts []string) (string, error)