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 GetChartsFolder() string
• func GetClientSetForTest(t *testing.T) *kubernetes.Clientset
• func IsConnectionRefusedError(err error) bool
• func IsNeedWaitError(err error) bool
• func IsUnexpectedEOFError(err error) bool
• 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 ValidateDatasets(dataset []string) (err error)
• func ValidateJobName(value string) error
• func ValidatePriorityClassName(client *kubernetes.Clientset, prioityClassName string) error

Constants

const AUTO_SELECT_PORT_MAX = 30000

const AUTO_SELECT_PORT_MIN = 20000

const DNS1123LabelMaxLength int = 63

const DNS1123SubdomainMaxLength int = 253

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

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

func ValidatePriorityClassName

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

Check if PriorityClassName exists