handler

package
v0.0.0-...-b025b39 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 1, 2023 License: GPL-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IJobHandler

type IJobHandler interface {
	//初始化方法
	//@author: Frank Fan
	// @param  context JobContext 任务执行上下文
	// @param  xxlLogger *tools.XxlJobFileLogger 向调度器后台上报日志的工具
	Init(context JobContext, xxlLogger *tools.XxlJobFileLogger)
	//销毁方法
	//@author: Frank Fan
	// @param  context JobContext 任务执行上下文
	// @param  xxlLogger *tools.XxlJobFileLogger 向调度器后台上报日志的工具
	Destroy(context JobContext, xxlLogger *tools.XxlJobFileLogger)
	//任务执行逻辑
	//@author: Frank Fan
	//@param param string 后台填写的参数
	// @param  context JobContext 任务执行上下文
	// @param  xxlLogger *tools.XxlJobFileLogger 向调度器后台上报日志的工具
	Execute(param string, context JobContext, xxlLogger *tools.XxlJobFileLogger) ReturnT
}

type JobContext

type JobContext struct {
	JobId int32 `json:"jobId"`

	ExecutorHandler       string `json:"executorHandler"`
	ExecutorParams        string `json:"executorParams"`
	ExecutorBlockStrategy string `json:"executorBlockStrategy"`
	ExecutorTimeout       int    `json:"executorTimeout"`

	LogId       int64 `json:"logId"`
	LogDateTime int64 `json:"logDateTime"`

	//仅仅支持 bean 类型
	GlueType string `json:"glueType"`

	BroadcastIndex int32 `json:"broadcastIndex"`
	BroadcastTotal int32 `json:"broadcastTotal"`
}

func (JobContext) String

func (t JobContext) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL