utils

Documentation

Index

• func Contains(slice []string, item string) bool
• func ExecCmd(cmd string, args ...string) (string, error)
• func FileExists(filePath string) bool
• func FileRelative(p string) (string, error)
• func GetCommonHome() (string, error)
• func GetHomeDirectory() (string, error)
• func ReadUrlAndWrite(filepath string, url string) (err error)
• func ReturnPath(files []string) string
• func WaitFor(fn func() (bool, error), opts *WaitForOpts) error
• type K8sClient
  • func NewK8sClient() (*K8sClient, error)
  • func (c *K8sClient) AllPodsAreReady(namespace string) (bool, error)
  • func (c *K8sClient) Exec(p *core_v1.Pod, command []string) (string, error)
  • func (c *K8sClient) GetPod(namespace string, podname string) (p *core_v1.Pod, err error)
• type WaitForOpts

Functions

func Contains

func Contains(slice []string, item string) bool

func ExecCmd

func ExecCmd(cmd string, args ...string) (string, error)

func FileExists

func FileExists(filePath string) bool

func FileRelative

func FileRelative(p string) (string, error)

func GetCommonHome

func GetCommonHome() (string, error)

func GetHomeDirectory

func GetHomeDirectory() (string, error)

func ReadUrlAndWrite

func ReadUrlAndWrite(filepath string, url string) (err error)

func ReturnPath

func ReturnPath(files []string) string

func WaitFor

func WaitFor(fn func() (bool, error), opts *WaitForOpts) error

Types

type K8sClient

type K8sClient struct {
	// contains filtered or unexported fields
}

func NewK8sClient

func NewK8sClient() (*K8sClient, error)

func (*K8sClient) AllPodsAreReady

func (c *K8sClient) AllPodsAreReady(namespace string) (bool, error)

func (*K8sClient) Exec

func (c *K8sClient) Exec(p *core_v1.Pod, command []string) (string, error)

func (*K8sClient) GetPod

func (c *K8sClient) GetPod(namespace string, podname string) (p *core_v1.Pod, err error)

type WaitForOpts

type WaitForOpts struct {
	Condition string
	Interval  time.Duration
	Timeout   time.Duration
}