Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

xxljob

package module

Go to main page

Versions in this module

v1

v1.0.2

Aug 6, 2021

Changes in this version

+ const SERVER_PORT

v1.0.1

Aug 2, 2021

v1.0.0

Jul 23, 2021

Changes in this version

type EsClient

+ Servers []string

+ func (e *EsClient) Connect() error

type Executor

+ Beat func(writer http.ResponseWriter, request *http.Request)

+ IdleBeat func(writer http.ResponseWriter, request *http.Request)

v0

v0.0.1

Jul 22, 2021

Changes in this version

+ const INDEX_KEY_PREFIX

+ var DefaultExecutorPort = "9999"

+ var DefaultRegistryKey = "golang-jobs"

+ func Int64ToStr(i int64) string

+ type EsClient struct

+ AppId string

+ Env string

+ Server string

+ func (e *EsClient) AddLog(logEs *LogEs) error

+ func (e *EsClient) ReadLog(logId int64) ([]interface{}, error)

+ type ExecuteResult struct

+ Code int64

+ Msg interface{}

+ type Executor interface

+ Init func(...Option)

+ KillTask func(writer http.ResponseWriter, request *http.Request)

+ LogHandler func(handler LogHandler)

+ RegTask func(pattern string, task TaskFunc)

+ Run func() error

+ RunTask func(writer http.ResponseWriter, request *http.Request)

+ Stop func()

+ TaskLog func(writer http.ResponseWriter, request *http.Request)

+ func NewExecutor(opts ...Option) Executor

+ type LogEs struct

+ Contents []string

+ Locker *sync.Mutex

+ LogId int64

+ func NewLogEs() *LogEs

+ func (l *LogEs) Error(logId int64, format string, log ...interface{})

+ func (l *LogEs) Flush()

+ func (l *LogEs) Info(logId int64, format string, log ...interface{})

+ func (l *LogEs) InitEs(server string, appId string, env string) *LogEs

+ type LogFunc func(req LogReq, res *LogRes) []byte

+ type LogHandler func(req *LogReq) *LogRes

+ type LogReq struct

+ FromLineNum int

+ LogDateTim int64

+ LogID int64

+ type LogRes struct

+ Code int64

+ Content LogResContent

+ Msg string

+ func EsLogHandler(req *LogReq) *LogRes

+ type LogResContent struct

+ FromLineNum int

+ IsEnd bool

+ LogContent string

+ ToLineNum int

+ type Logger interface

+ Error func(logId int64, format string, a ...interface{})

+ Flush func()

+ Info func(logId int64, format string, a ...interface{})

+ type Option func(o *Options)

+ func AccessToken(token string) Option

+ func ExecutorIp(ip string) Option

+ func ExecutorPort(port string) Option

+ func RegistryKey(registryKey string) Option

+ func ServerAddr(addr string) Option

+ func SetLogger(l Logger) Option

+ type Options struct

+ AccessToken string

+ ExecutorIp string

+ ExecutorPort string

+ LogDir string

+ RegistryKey string

+ ServerAddr string

+ Timeout time.Duration

+ type Registry struct

+ RegistryGroup string

+ RegistryKey string

+ RegistryValue string

+ type RunReq struct

+ BroadcastIndex int64

+ BroadcastTotal int64

+ ExecutorBlockStrategy string

+ ExecutorHandler string

+ ExecutorParams string

+ ExecutorTimeout int64

+ GlueSource string

+ GlueType string

+ GlueUpdatetime int64

+ JobID int64

+ LogDateTime int64

+ LogID int64

+ type Task struct

+ Cancel context.CancelFunc

+ EndTime int64

+ Ext context.Context

+ Id int64

+ LogId int64

+ Name string

+ Param *RunReq

+ StartTime int64

+ func (t *Task) Info() string

+ func (t *Task) Run(callback func(code int64, msg string))

+ type TaskFunc func(cxt context.Context, param *RunReq, logger Logger) string