util

Documentation

Index

• Constants
• func AcquireAllPods(namespace string, client *kubernetes.Clientset) ([]v1.Pod, error)
• func AcquireServingServices(namespace string, client *kubernetes.Clientset) ([]v1.Service, error)
• func GenerateRsaKey() (map[string]string, error)
• func GetChartsFolder() string
• func GetClientSetForTest(t *testing.T) *kubernetes.Clientset
• func GetFormatTime(timestamp int64) string
• func IsConnectionRefusedError(err error) bool
• func IsNeedWaitError(err error) bool
• func IsUnexpectedEOFError(err error) bool
• func Md5(str string) string
• func ParseDataDirRaw(raw string) (hostPath, containerPath string, err error)
• func RandomInt32() string
• func Retry(attempts int, sleep time.Duration, callback func() error) (err error)
• func RetryDuring(duration time.Duration, sleep time.Duration, callback func() error) (err error)
• func SelectAvailablePort(client *kubernetes.Clientset) (int, error)
• func SelectAvailablePortWithDefault(client *kubernetes.Clientset, port int) (int, error)
• func SetLogLevel(level string)
• func ShortHumanDuration(d time.Duration) string
• func StringInSlice(x string, list []string) bool
• func ValidateDatasets(dataset []string) (err error)
• func ValidateDevices(devices []string) error
• func ValidateJobName(value string) error
• func ValidatePriorityClassName(client *kubernetes.Clientset, name string) error

Constants

const AUTO_SELECT_PORT_MAX = 30000

const AUTO_SELECT_PORT_MIN = 20000

const JobMaxLength int = 49

Job Max lenth should be 49

Functions

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 ValidateDevices

func ValidateDevices(devices []string) 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