tools

Documentation

Index

• Constants
• Variables
• func CheckErr(err error, explain ...string)
• func CreatCR()
• func CreatVarsCM(subStr string)
• func CreatVarsCMFile(subStr string) string
• func CreateClusterByApply(installYamlPath string)
• func DoCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)
• func DoErrCmd(cmd exec.Cmd) (bytes.Buffer, bytes.Buffer)
• func DoSonoBuoyCheck(masterSSH string)
• func FlagParse()
• func GetKuBeanPath() string
• func NewDoCmd(cmd string, args ...string) (bytes.Buffer, bytes.Buffer)
• func NodePingPod(sshNode, podIP string)
• func PodPingPod(node, podFromNs, podFromName, podToIP string)
• func RemoteSSHCmdArray(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

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

Variables

var ClusterOperationName string

var Kubeconfig string

var Vmipaddr string

var Vmipaddr2 string

Functions

func CheckErr

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

func CreatCR

func CreatCR()

func CreatVarsCM

func CreatVarsCM(subStr string)

func CreatVarsCMFile

func CreatVarsCMFile(subStr string) string

func CreateClusterByApply

func CreateClusterByApply(installYamlPath 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 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 PodPingPod

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

func RemoteSSHCmdArray

func RemoteSSHCmdArray(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"`
	}
}