utils

Documentation

Index

• func DeleteRelease(name, namespace string) error
• func EnsureNamespace(ns string) error
• func GetMPIJob(name, ns string) (*batchv1.MPIJob, error)
• func GetNamespace(ns string) error
• func GetPodLog(name, ns string, follow bool) error
• func GetReleaseValue(name, namespace string) error
• func InitKubeClient() error
• func InstallRelease(name string, namespace string, values interface{}) error
• func KubectlCp(src string, dst string, containername string, ns string) (*bytes.Buffer, *bytes.Buffer, *bytes.Buffer, error)
• func ListMPIJob(ns string) (*batchv1.MPIJobList, error)
• func PrintMPIJobList(mpijobs *batchv1.MPIJobList)
• func WaitPodRunning(name, ns string, numWorkers int)

Functions

func DeleteRelease

func DeleteRelease(name, namespace string) error

func EnsureNamespace

func EnsureNamespace(ns string) error

func GetMPIJob

func GetMPIJob(name, ns string) (*batchv1.MPIJob, error)

func GetNamespace

func GetNamespace(ns string) error

func GetPodLog

func GetPodLog(name, ns string, follow bool) error

func GetReleaseValue

func GetReleaseValue(name, namespace string) error

func InitKubeClient

func InitKubeClient() error

func InstallRelease

func InstallRelease(name string, namespace string, values interface{}) error

func KubectlCp

func KubectlCp(src string, dst string, containername string, ns string) (*bytes.Buffer, *bytes.Buffer, *bytes.Buffer, error)

KubectlCp copied from https://stackoverflow.com/questions/51686986/how-to-copy-file-to-container-with-kubernetes-client-go

func ListMPIJob

func ListMPIJob(ns string) (*batchv1.MPIJobList, error)

func PrintMPIJobList

func PrintMPIJobList(mpijobs *batchv1.MPIJobList)

func WaitPodRunning

func WaitPodRunning(name, ns string, numWorkers int)