update

go.mod

@@ -35,7 +35,7 @@ require (
 	github.com/swaggo/swag v1.8.12
 	github.com/uptrace/opentelemetry-go-extra/otelgorm v0.2.3
 	github.com/vmihailenco/msgpack v4.0.4+incompatible
-	gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3
+	gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.4
 	go.opentelemetry.io/contrib v1.24.0
 	go.opentelemetry.io/otel v1.24.0
 	go.opentelemetry.io/otel/exporters/jaeger v1.17.0

go.sum

@@ -608,8 +608,8 @@ github.com/yuin/gopher-lua v0.0.0-20210529063254-f4c35e4016d9 h1:k/gmLsJDWwWqbLC
 github.com/yuin/gopher-lua v0.0.0-20210529063254-f4c35e4016d9/go.mod h1:E1AXubJBdNmFERAOucpDIxNzeGfLzg0mYh+UfMWdChA=
 github.com/yusufpapurcu/wmi v1.2.3 h1:E1ctvB7uKFMOJw3fdOW32DwGE9I7t++CRUEMKvFoFiw=
 github.com/yusufpapurcu/wmi v1.2.3/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
-gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3 h1:xjmaDtDja2iDrQJgWpaiEI/oKwXbVCOY43tgSqFTqIU=
-gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3/go.mod h1:aa6yOw4iYog1VGo7k27pdbGzEuXy4jgA14pM4FGMTVE=
+gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.4 h1:QnE5ezPilfRfIAUKUkAsyFBihwP5c6FIz9o7fK/yM1I=
+gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.4/go.mod h1:aa6yOw4iYog1VGo7k27pdbGzEuXy4jgA14pM4FGMTVE=
 go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
 go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
 go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=

xcron/xcron.go

@@ -46,14 +46,14 @@ func initXCron() {
 }
 
 type jobMap struct {
-	m map[string]xxl.TaskFunc
+	m map[string]xxl.TaskFn
 }
 
 var JobMap = &jobMap{
-	m: make(map[string]xxl.TaskFunc),
+	m: make(map[string]xxl.TaskFn),
 }
 
-func (x *jobMap) add(k string, h xxl.TaskFunc) {
+func (x *jobMap) add(k string, h xxl.TaskFn) {
 	x.m[k] = h
 }
 
@@ -61,13 +61,13 @@ func (x *jobMap) isEmpty() bool {
 	return len(x.m) == 0
 }
 
-func (x *jobMap) ForEach(f func(k string, h xxl.TaskFunc)) {
+func (x *jobMap) ForEach(f func(k string, h xxl.TaskFn)) {
 	for k, v := range x.m {
 		f(k, v)
 	}
 }
 
-func Add(k string, h xxl.TaskFunc) {
+func Add(k string, h xxl.TaskFn) {
 	JobMap.add(k, h)
 }
 
@@ -106,7 +106,7 @@ func xxlJob(r *gin.Engine) {
 
 	xxl.XxlJobMux(r, xxlExecutor)
 
-	JobMap.ForEach(func(k string, h xxl.TaskFunc) {
+	JobMap.ForEach(func(k string, h xxl.TaskFn) {
 		xxlExecutor.RegTask(k, h)
 	})
 
@@ -131,7 +131,7 @@ func (l *log) Error(format string, a ...interface{}) {
 	logger.Errorf("[xxl-executor]%s", fmt.Sprintf(format, a...))
 }
 
-func customMiddleware(tf xxl.TaskFunc) xxl.TaskFunc {
+func customMiddleware(tf xxl.TaskFn) xxl.TaskFn {
 	return func(cxt context.Context, req *xxl.RunReq) string {
 		logger.Info("[xxl-executor][middleware]=====req=====", logger.Any("req", req))
 		res := tf(cxt, req)