xxl

Jan 10, 2022

Changes in this version

+ const CoverEarly

+ const DefaultExecutorPort

+ const DefaultRegistryKey

+ const DiscardLater

+ const GlueTypeBEAN

+ const GlueTypeGROOVY

+ const GlueTypeNODEJS

+ const GlueTypePHP

+ const GlueTypePOWERSHELL

+ const GlueTypePYTHON

+ const GlueTypeSHELL

+ const SerialExecution

+ func IsScript(glueType string) bool

+ type Executor struct

+ func (e *Executor) Job(handlerName string, handler job.Func)

+ func (e *Executor) Run()

+ func (e *Executor) WithDebug(debug bool)

+ func (e *Executor) WithHealthCheck(path string, handler server.Handler)

+ func (e *Executor) WrapF(f func(w http.ResponseWriter, r *http.Request)) server.Handler

+ type ExecutorBiz struct

+ func NewExecutorService() *ExecutorBiz

+ func (biz *ExecutorBiz) Beat(ctx *server.Context)

+ func (biz *ExecutorBiz) IdleBeat(ctx *server.Context)

+ func (biz *ExecutorBiz) Kill(ctx *server.Context)

+ func (biz *ExecutorBiz) Log(ctx *server.Context)

+ func (biz *ExecutorBiz) Run(ctx *server.Context)

+ type HealthFunc func(ctx *server.Context)

+ type JobExecutor interface

+ Job func(handlerName string, handler job.Func)

+ Run func()

+ WithDebug func(isDebug bool)

+ WithHealthCheck func(path string, handler server.Handler)

+ func NewExecutor(opts ...Option) JobExecutor

+ type LogReq struct

+ FromLineNum int

+ LogDateTim int64

+ LogId int

+ type LogResp struct

+ FromLineNum int

+ IsEnd bool

+ LogContent string

+ ToLineNum int

+ type Option func(o *Options)

+ func AccessToken(token string) Option

+ func AdmAdmAddresses(addr ...string) Option

+ func ExecutorIp(ip string) Option

+ func ExecutorPort(port string) Option

+ func RegistryKey(registryKey string) Option

+ type Options struct

+ AccessToken string

+ AdmAddresses []string

+ ExecutorIp string

+ ExecutorPort string

+ RegistryKey string

+ RegistryValue string

+ Timeout time.Duration