tools

Documentation

Index

• Constants
• Variables
• func CheckErr(err error, explain ...string)
• func CreatVarsCM(subStr string)
• func CreatVarsCMFile(subStr string) string
• func CreateClusterByApply(installYamlPath string)
• func CreatePod(podName, namespace, nodeName, image, kubeconfigFile string)
• func DoCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)
• func DoErrCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)
• func DoSonoBuoyCheck(masterSSH string)
• func DoSonoBuoyCheckByPasswd(password, masterSSH string)
• func FlagParse()
• func GetKuBeanPath() string
• func NewDoCmd(cmd string, args ...string) (bytes.Buffer, bytes.Buffer)
• func NodePingPod(sshNode, podIP string)
• func NodePingPodByPasswd(password, sshNode, podIP string)
• func OperateClusterByYaml(clusterInstallYamlsPath, operatorName string, kindConfig *restclient.Config)
• func PodPingPod(node, podFromNs, podFromName, podToIP string)
• func PodPingPodByPasswd(password, node, podFromNs, podFromName, podToIP string)
• func RemoteSSHCmdArray(subCmd []string) []string
• func RemoteSSHCmdArrayByPasswd(password string, subCmd []string) []string
• func SaveKubeConf(kindConfig *restclient.Config, clusterName, configToSavePath string)
• func SvcCurl(ip string, port int32, checkString string, timeTotalSecond time.Duration, ...)
• func UpdateBackoffLimit(content int, filePath string)
• func UpdateOpsYml(content string, filePath string)
• func WaitKubeanJobPodToSuccess(kubeClient *kubernetes.Clientset, podNamespace, podName, expectedStatus string)
• func WaitPodBeRunning(kubeClient *kubernetes.Clientset, namespace, podName string, ...) *v1.Pod
• func WaitPodSInKubeSystemBeRunning(kubeClient *kubernetes.Clientset, timeTotalSecond time.Duration, ...)
• type KubeanOpsYml
• type OfflineConfig
  • func InitOfflineConfig() OfflineConfig

Constants

const (
	PodStatusSucceeded = "Succeeded"
	PodStatusFailed    = "Failed"
	PodStatusRunning   = "Running"
)

k8s const

const (
	KubeanNamespace     = "kubean-system"
	KubeSystemNamespace = "kube-system"
	DefaultNamespace    = "default"
	TestClusterName     = "cluster1"
	LocalKubeConfigPath = "cluster1-config"
)

kubean_const

const (
	OriginK8Version    = "v1.24.7"
	UpgradeK8Version_Y = "v1.25.3"
	UpgradeK8Version_Z = "v1.25.5"
)

Variables

var Arch string

var ClusterOperationName string

var IsOffline string

var Kubeconfig string

var OfflineConfigStr string

var OtherLabel string

var VmPassword string

var Vmipaddr string

var Vmipaddr2 string

Functions

func CheckErr

func CheckErr(err error, explain ...string)

func CreatVarsCM

func CreatVarsCM(subStr string)

func CreatVarsCMFile

func CreatVarsCMFile(subStr string) string

func CreateClusterByApply

func CreateClusterByApply(installYamlPath string)

func CreatePod

func CreatePod(podName, namespace, nodeName, image, kubeconfigFile string)

func DoCmd

func DoCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)

func DoErrCmd

func DoErrCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)

func DoSonoBuoyCheck

func DoSonoBuoyCheck(masterSSH string)

func DoSonoBuoyCheckByPasswd

func DoSonoBuoyCheckByPasswd(password, masterSSH string)

func FlagParse

func FlagParse()

func GetKuBeanPath

func GetKuBeanPath() string

func NewDoCmd

func NewDoCmd(cmd string, args ...string) (bytes.Buffer, bytes.Buffer)

func NodePingPod

func NodePingPod(sshNode, podIP string)

func NodePingPodByPasswd

func NodePingPodByPasswd(password, sshNode, podIP string)

func OperateClusterByYaml

func OperateClusterByYaml(clusterInstallYamlsPath, operatorName string, kindConfig *restclient.Config)

func PodPingPod

func PodPingPod(node, podFromNs, podFromName, podToIP string)

func PodPingPodByPasswd

func PodPingPodByPasswd(password, node, podFromNs, podFromName, podToIP string)

func RemoteSSHCmdArray

func RemoteSSHCmdArray(subCmd []string) []string

func RemoteSSHCmdArrayByPasswd

func RemoteSSHCmdArrayByPasswd(password string, subCmd []string) []string

func SaveKubeConf

func SaveKubeConf(kindConfig *restclient.Config, clusterName, configToSavePath string)

func SvcCurl

func SvcCurl(ip string, port int32, checkString string, timeTotalSecond time.Duration, ops ...time.Duration)

func UpdateBackoffLimit

func UpdateBackoffLimit(content int, filePath string)

func UpdateOpsYml

func UpdateOpsYml(content string, filePath string)

func WaitKubeanJobPodToSuccess

func WaitKubeanJobPodToSuccess(kubeClient *kubernetes.Clientset, podNamespace, podName, expectedStatus string)

func WaitPodBeRunning

func WaitPodBeRunning(kubeClient *kubernetes.Clientset, namespace, podName string, timeTotalSecond time.Duration, ops ...time.Duration) *v1.Pod

func WaitPodSInKubeSystemBeRunning

func WaitPodSInKubeSystemBeRunning(kubeClient *kubernetes.Clientset, timeTotalSecond time.Duration, ops ...time.Duration)

Types

type KubeanOpsYml

type KubeanOpsYml struct {
	ApiVersion string `yaml:"apiVersion"`
	Kind       string `yaml:"kind"`
	Metadata   struct {
		Name   string `yaml:"name"`
		Labels struct {
			ClusterName string `yaml:"clusterName"`
		}
	}
	Spec struct {
		Cluster      string `yaml:"cluster"`
		Image        string `yaml:"image"`
		BackoffLimit int    `yaml:"backoffLimit"`
		ActionType   string `yaml:"actionType"`
		Action       string `yaml:"action"`
	}
}

type OfflineConfig

type OfflineConfig struct {
	Ip              string `yaml:"ip"`
	RegistryAddr    string `yaml:"registry_addr"`
	MinioAddr       string `yaml:"minio_addr"`
	NginxImageAMD64 string `yaml:"nginx_image_amd64"`
	NginxImageARM64 string `yaml:"nginx_image_arm64"`
}

func InitOfflineConfig

func InitOfflineConfig() OfflineConfig