master

package
v0.0.0-...-ad569dd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 23, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitApiServer

func InitApiServer() (err error)

初始化http配置

func InitConfig

func InitConfig(filename string) (err error)

加载配置

func InitJobMgr

func InitJobMgr() (err error)

初始化管理器

func InitLogMgr

func InitLogMgr() (err error)

func InitWorkerMgr

func InitWorkerMgr() (err 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)

删除job

func (*JobMgr) KillJob

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

杀死任务

func (*JobMgr) ListJobs

func (jobMgr *JobMgr) ListJobs() (jobLists []*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
}
var (
	G_workerMgr *WorkerMgr
)

func (*WorkerMgr) ListWorkers

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

获取在线worker列表

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL