Documentation
¶
Index ¶
- func CopyLocalRepoToMPIJob(url string, mpijob *batchv1.MPIJob)
- 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 GetPod(name, ns string) (*v1.Pod, error)
- func GetReleaseValue(name, namespace string) error
- func GetStatefulSet(name, ns string) (*appsv1.StatefulSet, 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 NewMPIClient() (*versioned.Clientset, error)
- func PrintMPIJobList(mpijobs *batchv1.MPIJobList)
- func PrintMPIJobLog(mpijob *batchv1.MPIJob, follow bool)
- func PrintPodLog(name, ns string, follow bool) error
- func WaitMPIJobPodRunning(mpijob *batchv1.MPIJob) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopyLocalRepoToMPIJob ¶
func DeleteRelease ¶
func EnsureNamespace ¶
func GetNamespace ¶
func GetReleaseValue ¶
func GetStatefulSet ¶
func GetStatefulSet(name, ns string) (*appsv1.StatefulSet, error)
func InitKubeClient ¶
func InitKubeClient() error
func InstallRelease ¶
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 NewMPIClient ¶
func PrintMPIJobList ¶
func PrintMPIJobList(mpijobs *batchv1.MPIJobList)
func PrintMPIJobLog ¶
func PrintPodLog ¶
func WaitMPIJobPodRunning ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.