monitor

Documentation

Index

• type JobStatus
• type SimpleMonitor
  • func New(k8sClient *kubernetes.Clientset, namespace string) SimpleMonitor
  • func (monitor *SimpleMonitor) GetJobStatus(jobID string) (JobStatus, error)

Types

type JobStatus

type JobStatus struct {
	Status   api.JobStatusEnum
	ErrorMsg string
}

type SimpleMonitor

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

func New

func New(k8sClient *kubernetes.Clientset, namespace string) SimpleMonitor

func (*SimpleMonitor) GetJobStatus

func (monitor *SimpleMonitor) GetJobStatus(jobID string) (JobStatus, error)