util

func GetChartsFolder ¶

func GetChartsFolder() string

func GetClientSetForTest ¶

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

func IsConnectionRefusedError ¶

func IsConnectionRefusedError(err error) bool

func IsNeedWaitError ¶

func IsNeedWaitError(err error) bool

func IsUnexpectedEOFError ¶

func IsUnexpectedEOFError(err error) bool

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 ValidateDatasets ¶

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

func ValidateJobName ¶

func ValidateJobName(value string) error