master

Documentation

Index

• func InitApiServer() (err error)
• func InitConfig(filename string) (err error)
• func InitJobMgr() (err error)
• func RegisterRouter() *httprouter.Router
• type ApiServer
• type Config
• type ErrorJob
  • func (e *ErrorJob) Error() string
• type JobMgr
  • func (jobMgr *JobMgr) DelJob(jobName string) (oldJobs []common.Job, err error)
  • func (jobMgr *JobMgr) SaveJob(job *common.Job) (oldJob common.Job, err error)

Functions

func InitApiServer

func InitApiServer() (err error)

初始化服务

func InitConfig

func InitConfig(filename string) (err error)

func InitJobMgr

func InitJobMgr() (err error)

func RegisterRouter

func RegisterRouter() *httprouter.Router

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"`
}

var (
	G_config *Config
)

type ErrorJob

type ErrorJob struct {
	Msg string
}

func (*ErrorJob) Error

func (e *ErrorJob) Error() string

type JobMgr

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

任务管理器

var (
	G_jobMgr *JobMgr
)

func (*JobMgr) DelJob

func (jobMgr *JobMgr) DelJob(jobName string) (oldJobs []common.Job, err error)

func (*JobMgr) SaveJob

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