Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( JobGVK = k8s.MPIJobGVK KubeMPIFwVersion = client.KubeFrameworkVersion(JobGVK) )
Functions ¶
func New ¶
func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface
Types ¶
type KubeMPIJob ¶
type KubeMPIJob struct {
kuberuntime.KubeBaseJob
}
KubeMPIJob is a struct that runs a mpi job
func (*KubeMPIJob) AddEventListener ¶
func (mj *KubeMPIJob) AddEventListener(ctx context.Context, listenerType string, jobQueue workqueue.RateLimitingInterface, listener interface{}) error
func (*KubeMPIJob) JobStatus ¶
func (mj *KubeMPIJob) JobStatus(obj interface{}) (api.StatusInfo, error)
JobStatus get the statusInfo of mpi job, including origin status, pf status and message
Source Files
Click to show internal directories.
Click to hide internal directories.