master

Documentation

Index

• func InitApiServer() (err error)
• func InitJobMgr() (err error)
• func InitLogMgr() (err error)
• type ApiServer
• type JobManager
  • func (jobMgr *JobManager) DeleteJob(name string) (oldJob *common.Job, err error)
  • func (jobMgr *JobManager) KillJob(jobName string) (err error)
  • func (jobMgr *JobManager) ListJobs() (jobList []*common.Job, err error)
  • func (jobMgr *JobManager) SaveJob(job *common.Job) (oldJob *common.Job, err error)
• type LogManager
  • func (logMgr *LogManager) ListLog(name string, skip int, limit int) (logArr []*common.JobLog, err error)

Functions

func InitApiServer

func InitApiServer() (err error)

Initialize the service

func InitJobMgr

func InitJobMgr() (err error)

func InitLogMgr

func InitLogMgr() (err error)

Types

type ApiServer

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

Job http service

type JobManager

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

func (*JobManager) DeleteJob

func (jobMgr *JobManager) DeleteJob(name string) (oldJob *common.Job, err error)

func (*JobManager) KillJob

func (jobMgr *JobManager) KillJob(jobName string) (err error)

func (*JobManager) ListJobs

func (jobMgr *JobManager) ListJobs() (jobList []*common.Job, err error)

func (*JobManager) SaveJob

func (jobMgr *JobManager) SaveJob(job *common.Job) (oldJob *common.Job, err error)

type LogManager

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

func (*LogManager) ListLog

func (logMgr *LogManager) ListLog(name string, skip int, limit int) (logArr []*common.JobLog, err error)