master

Documentation

Index

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

Functions

func InitApiServer

func InitApiServer() error

初始化服务

func InitConfig

func InitConfig(filename string) error

加载配置

func InitJobMgr

func InitJobMgr() error

初始化管理器

func InitLogMgr

func InitLogMgr() error

func InitWorkerMgr

func InitWorkerMgr() error

Types

type ApiServer

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

任务的HTTP接口

var G_apiServer *ApiServer

type Config

type Config struct {
	ApiPort               int      `json:"apiPort"`
	ApiReadTimeout        int      `json:"apiReadTimeout"`
	ApiWriteTimeout       int      `json:"apiWriteTimeout"`
	EtcdEndpoints         []string `json:"etcdEndpoints"`
	EtcdDialTimeout       int      `json:"etcdDialTimeout"`
	WebRoot               string   `json:"webroot"`
	MongodbUri            string   `json:"mongodbUri"`
	MongodbConnectTimeout int      `json:"mongodbConnectTimeout"`
}

程序配置

var (
	// 单例
	G_config *Config
)

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) error

杀死任务

func (*JobMgr) ListJobs

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

列举任务

func (*JobMgr) SaveJob

func (jobMgr *JobMgr) SaveJob(job *common.Job) (*common.Job, 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) ([]*common.JobLog, error)

查看任务日志

type WorkerMgr

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

/cron/workers/

var G_workerMgr *WorkerMgr

func (*WorkerMgr) ListWorkers

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

获取在线worker列表