Documentation ¶
Index ¶
- func ClearLogHandler(tr interface{}) error
- func DisableAndUpdateTask(o orm.Ormer, old_task *md.Task, update_filed *orm.Params) (int64, error)
- func GetTaskInfo(o orm.Ormer, task_id int64) (md.Task, error)
- func GetUpdateField(task *md.Task) (fields orm.Params, is_update_th bool, err error)
- func HandleAddTask(c *gin.Context)
- func HandleQueryTaskStatus(c *gin.Context)
- func HandleRunAgain(c *gin.Context)
- func HandleServerRecover()
- func HandleUpdateTask(c *gin.Context)
- func InitInnerCron()
- func IsTaskNeedRun(task md.Task) bool
- func IsValidTask(task *md.Task) (bool, error)
- func ReadRequestJson(c *gin.Context, obj interface{}) error
- func RetryTask(n *bt.Node)
- func RunTask(o orm.Ormer, r bt.RunType, task md.Task) error
- func TimerHandler(tr interface{}) error
- func WriteRespons(c *gin.Context, code int, msg string, data interface{})
- type AddTaskReq
- type AddTaskResp
- type QueryLogArg
- type QueryLogResp
- type Response
- type Result
- type RunAgainReq
- type RunAgainResp
- type TaskInfo
- type UpdateTaskReq
- type UpdateTaskResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClearLogHandler ¶
func ClearLogHandler(tr interface{}) error
func DisableAndUpdateTask ¶
目的废弃旧的taskid,再新增一个
func GetUpdateField ¶
func HandleQueryTaskStatus ¶
func HandleRunAgain ¶
func HandleServerRecover ¶
func HandleServerRecover()
func HandleUpdateTask ¶
func InitInnerCron ¶
func InitInnerCron()
func ReadRequestJson ¶
func TimerHandler ¶
func TimerHandler(tr interface{}) error
Types ¶
type AddTaskResp ¶
type AddTaskResp struct {
ResultList []Result `json:"task_result"`
}
type QueryLogResp ¶
type RunAgainResp ¶
type RunAgainResp struct {
ResultList []Result `json:"task_result"`
}
type UpdateTaskResp ¶
type UpdateTaskResp struct {
ResultList []Result `json:"task_result"`
}
Click to show internal directories.
Click to hide internal directories.