master

Documentation

Index

• func InitJobMgr() (err error)
• func InitLogMgr() (err error)
• func InitWorkerMgr() (err error)
• type JobMgr
  • func (jobMgr *JobMgr) DeleteJob(name string) (oldJob *common.Job, err error)
  • func (jobMgr *JobMgr) KillJob(name string) (err error)
  • func (jobMgr *JobMgr) ListJobs() (jobList []*common.Job, err error)
  • func (jobMgr *JobMgr) SaveJob(job *common.Job) (oldJob *common.Job, err error)
• type LogMgr
  • func (logMgr *LogMgr) ListLog(name string, skip int, limit int) (logArr []*common.JobLog, err error)
• type WorkerMgr
  • func (workerMgr *WorkerMgr) ListWorkers() (workerArr []string, err error)

Functions

func InitJobMgr

func InitJobMgr() (err error)

初始化管理器

func InitLogMgr

func InitLogMgr() (err error)

func InitWorkerMgr

func InitWorkerMgr() (err error)

Types

type JobMgr

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

任务管理器

var (
	// 单例
	G_jobMgr *JobMgr
)

func (*JobMgr) DeleteJob

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

删除任务

func (*JobMgr) KillJob

func (jobMgr *JobMgr) KillJob(name string) (err error)

杀死任务

func (*JobMgr) ListJobs

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

列举任务

func (*JobMgr) SaveJob

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

保存任务

type LogMgr

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

mongodb日志管理

var (
	G_logMgr *LogMgr
)

func (*LogMgr) ListLog

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

查看任务日志

type WorkerMgr

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

/cron/workers/

func (*WorkerMgr) ListWorkers

func (workerMgr *WorkerMgr) ListWorkers() (workerArr []string, err error)

获取在线worker列表