monitor

Documentation

Index

• type JobStatus
• type SimpleMonitor
  • func New(k8sClient kubernetes.Interface, namespace string, db *database.Handler) SimpleMonitor
  • func (monitor *SimpleMonitor) GetJobStatus(jobID string) (JobStatus, error)
  • func (monitor *SimpleMonitor) RunFindStragglersLoop()

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.Interface, namespace string, db *database.Handler) SimpleMonitor

func (*SimpleMonitor) GetJobStatus

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

func (*SimpleMonitor) RunFindStragglersLoop

func (monitor *SimpleMonitor) RunFindStragglersLoop()