util

func AcquireAllPods ¶

func AcquireAllPods(namespace string, client *kubernetes.Clientset) ([]v1.Pod, error)

func AcquireServingServices ¶

func AcquireServingServices(namespace string, client *kubernetes.Clientset) ([]v1.Service, error)

func GenerateRsaKey ¶

func GenerateRsaKey() (map[string]string, error)

func GetChartsFolder ¶

func GetChartsFolder() string

func GetClientSetForTest ¶

func GetClientSetForTest(t *testing.T) *kubernetes.Clientset

func GetFormatTime ¶

func GetFormatTime(timestamp int64) string

func IsConnectionRefusedError ¶

func IsConnectionRefusedError(err error) bool

func IsNeedWaitError ¶

func IsNeedWaitError(err error) bool

func IsUnexpectedEOFError ¶

func IsUnexpectedEOFError(err error) bool

func Md5 ¶

func Md5(str string) string

func ParseDataDirRaw ¶

func ParseDataDirRaw(raw string) (hostPath, containerPath string, err error)

ParseDataDirRaw parse DataDir into hostPath, containerPath

func RandomInt32 ¶

func RandomInt32() string

RandomInt32 just generates a random string of int32

func Retry ¶

func Retry(attempts int, sleep time.Duration, callback func() error) (err error)

func RetryDuring ¶

func RetryDuring(duration time.Duration, sleep time.Duration, callback func() error) (err error)

func SelectAvailablePort ¶

func SelectAvailablePort(client *kubernetes.Clientset) (int, error)

Select a available port in range (AUTO_SELECT_PORT_MIN ~ AUTO_SELECT_PORT_MAX), and exclude used ports in k8s if 20000 is selected this time, make sure next time it will select 20001

func SelectAvailablePortWithDefault ¶

func SelectAvailablePortWithDefault(client *kubernetes.Clientset, port int) (int, error)

If default port is available, use it If not set defaultPort, select port automatically

func SetLogLevel ¶

func SetLogLevel(level string)

SetLogLevel sets the logrus logging level

func ShortHumanDuration ¶

func ShortHumanDuration(d time.Duration) string

ShortHumanDuration returns a succint representation of the provided duration with limited precision for consumption by humans.

func StringInSlice ¶

func StringInSlice(x string, list []string) bool

func ValidateDatasets ¶

func ValidateDatasets(dataset []string) (err error)

func ValidateJobName ¶

func ValidateJobName(value string) error

ValidateJobName validates the job name, its length should less than 63, and match dns1123LabelFmt

func ValidatePriorityClassName ¶

func ValidatePriorityClassName(client *kubernetes.Clientset, name string) error

Check if PriorityClassName exists