tools

package
v0.4.0-rc8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 21, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

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

k8s const

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

kubean_const

Variables

View Source
var ClusterOperationName string
View Source
var Kubeconfig string
View Source
var Vmipaddr string
View Source
var Vmipaddr2 string

Functions

func CheckErr added in v0.3.4

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

func CreatCR

func CreatCR()

func CreatVarsCM added in v0.3.0

func CreatVarsCM(subStr string)

func CreatVarsCMFile added in v0.3.0

func CreatVarsCMFile(subStr string) string

func CreateClusterByApply added in v0.4.0

func CreateClusterByApply(installYamlPath string)

func DoCmd added in v0.1.1

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

func DoErrCmd added in v0.2.2

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

func DoSonoBuoyCheck added in v0.3.4

func DoSonoBuoyCheck(masterSSH string)

func FlagParse

func FlagParse()

func GetKuBeanPath

func GetKuBeanPath() string

func NewDoCmd added in v0.2.6

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

func NodePingPod added in v0.3.4

func NodePingPod(sshNode, podIP string)

func PodPingPod added in v0.3.4

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

func RemoteSSHCmdArray added in v0.2.6

func RemoteSSHCmdArray(subCmd []string) []string

func SaveKubeConf added in v0.3.4

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

func SvcCurl added in v0.3.4

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

func UpdateBackoffLimit added in v0.2.1

func UpdateBackoffLimit(content int, filePath string)

func UpdateOpsYml

func UpdateOpsYml(content string, filePath string)

func WaitKubeanJobPodToSuccess added in v0.3.4

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

func WaitPodBeRunning added in v0.3.4

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

func WaitPodSInKubeSystemBeRunning added in v0.3.4

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"`
	}
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL