tools

Documentation

Index

• Constants
• Variables
• func CheckErr(err error, explain ...string)
• func CreatVarsCM(subStr string)
• func CreatVarsCMFile(subStr string) string
• func CreateDaemonSet(daemonsetName, namespace, imageName string, client *kubernetes.Clientset) *appsv1.DaemonSet
• 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 DoSonoBuoyCheckByPasswd(password, masterSSH string)
• func ExposeServiceToDaemonset(serviceName, serviceNamespace, svcType, sourceSelector string, ...) *corev1.Service
• func FlagParse()
• func GenerateClusterClient(localKubeConfigPath string) *kubernetes.Clientset
• func GetKuBeanPath() string
• func NewDoCmd(cmd string, args ...string) (bytes.Buffer, bytes.Buffer)
• func NewDoCmdSoft(cmd string, args ...string) (bytes.Buffer, error)
• func NodePingPodByPasswd(password, sshNode, podIP string)
• func OperateClusterByYaml(clusterInstallYamlsPath, operatorName string, kindConfig *restclient.Config, ...)
• 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(curIP string, curPort 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, ...) *corev1.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.27.5"
	UpgradeK8Version_Y          = "v1.28.0"
	UpgradeK8Version_Z          = "v1.27.6"
	NginxAlpha                  = "release-ci.daocloud.io/kubean/nginx:alpine"
	E2eInstallClusterYamlFolder = "e2e-install-cluster"
)

Variables

var Arch string

var ClusterOperationName string

var IsOffline string

var Kubeconfig string

var OfflineConfigStr string

var OtherLabel string

var Vipadd string

var VmPassword string

var Vmipaddr string

var Vmipaddr2 string

var Vmipaddr3 string

Functions

func CheckErr

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

func CreatVarsCM

func CreatVarsCM(subStr string)

func CreatVarsCMFile

func CreatVarsCMFile(subStr string) string

func CreateDaemonSet

func CreateDaemonSet(daemonsetName, namespace, imageName string, client *kubernetes.Clientset) *appsv1.DaemonSet

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 DoSonoBuoyCheckByPasswd

func DoSonoBuoyCheckByPasswd(password, masterSSH string)

func ExposeServiceToDaemonset

func ExposeServiceToDaemonset(serviceName, serviceNamespace, svcType, sourceSelector string, clientSet *kubernetes.Clientset) *corev1.Service

func FlagParse

func FlagParse()

func GenerateClusterClient

func GenerateClusterClient(localKubeConfigPath string) *kubernetes.Clientset

func GetKuBeanPath

func GetKuBeanPath() string

func NewDoCmd

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

func NewDoCmdSoft

func NewDoCmdSoft(cmd string, args ...string) (bytes.Buffer, error)

func NodePingPodByPasswd

func NodePingPodByPasswd(password, sshNode, podIP string)

func OperateClusterByYaml

func OperateClusterByYaml(clusterInstallYamlsPath, operatorName string, kindConfig *restclient.Config, args ...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(curIP string, curPort int32, checkString string, timeTotalSecond time.Duration, ops ...string)

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) *corev1.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