xxl-job-go-client

xxl-job 对应的golang客户端

提供Elasticsearch 日志组件，把job执行过程写入elasticsearch方便跟踪查询

 func main() {
    exec := xxl.NewExecutor(
    xxl.ServerAddr("http://192.168.1.50:8080/xxl-job-admin"),
    xxl.AccessToken(""), //请求令牌(默认为空)
    //xxl.ExecutorIp("xxl-job-executor-test"),    //可自动获取
    xxl.ExecutorPort("9999"),                     //默认9999（非必填）
    xxl.RegistryKey("golang-jobs"),               //执行器名称
    xxl.SetLogger(xxl.NewLogEs().InitEs([]string{"192.168.1.50:9200"}, "100058", "dev")), //自定义日志
    )
    exec.Init()
    //设置日志查看handler
    exec.LogHandler(xxl.EsLogHandler)
    //注册任务handler
    exec.RegTask("task.test", task.Test)
    exec.RegTask("task.test2", task.Test2)
    exec.RegTask("task.panic", task.Panic)
    log.Fatal(exec.Run())
}