v0

Documentation

Index

• func DelayJobDeliveryHandler(c *gin.Context)
• func DeleteJobHandler(c *gin.Context)
• func GetJobInfoHandler(c *gin.Context)
• func HealthCheckHandler(c *gin.Context)
• func PeriodicJobDeliveryHandler(c *gin.Context)
• func RecoveryJobHandler(c *gin.Context)
• func TerminateJobHandler(c *gin.Context)

Functions

func DelayJobDeliveryHandler

func DelayJobDeliveryHandler(c *gin.Context)

DelayJobDeliveryHandler 异步任务投递

@Summary		异步任务(非周期)投递
@Description	异步任务(非周期)投递
@Tags			任务投递
@Accept			application/json
@Produce		application/json
@Param			RequestBody	body		models.AsyncJob	true	"异步任务投递请求体"
@Success		200			{object}	web.Response
@Router			/api/async/v0/job/async [post]

func DeleteJobHandler

func DeleteJobHandler(c *gin.Context)

DeleteJobHandler 删除任务

@Summary		删除任务
@Description	删除任务
@Tags			任务删除
@Accept			application/json
@Produce		application/json
@Param			job	path		string	true	"任务id"
@Success		200	{object}	web.Response
@Router			/api/async/v0/job/{job} [delete]

func GetJobInfoHandler

func GetJobInfoHandler(c *gin.Context)

GetJobInfoHandler 查询任务信息

@Summary		查询任务信息
@Description	查询任务信息
@Tags			任务查询
@Accept			application/json
@Produce		application/json
@Param			job	path		string	true	"任务id"
@Success		200	{object}	web.Response{data=models.JobInfo}
@Router			/api/async/v0/job/{job} [get]

func HealthCheckHandler

func HealthCheckHandler(c *gin.Context)

HealthCheckHandler 健康检查

@Summary		健康检查
@Description	健康检查
@Tags			检查
@Accept			application/json
@Produce		application/json
@Success		200	{object}	web.Response
@Router			/api/async/v0/health [get]

func PeriodicJobDeliveryHandler

func PeriodicJobDeliveryHandler(c *gin.Context)

PeriodicJobDeliveryHandler 周期任务投递

@Summary		周期任务投递，支持cron语法
@Description	周期任务投递，支持cron语法
@Tags			任务投递
@Accept			application/json
@Produce		application/json
@Param			RequestBody	body		models.PeriodicJob	true	"周期任务投递请求体"
@Success		200			{object}	web.Response
@Router			/api/async/v0/job/periodic [post]

func RecoveryJobHandler

func RecoveryJobHandler(c *gin.Context)

RecoveryJobHandler 恢复任务

@Summary		恢复任务
@Description	恢复任务
@Tags			任务恢复
@Accept			application/json
@Produce		application/json
@Param			job	path		string	true	"任务id"
@Success		200	{object}	web.Response
@Router			/api/async/v0/job/{job}/recovery [patch]

func TerminateJobHandler

func TerminateJobHandler(c *gin.Context)

TerminateJobHandler 终止任务

@Summary		终止任务
@Description	终止任务
@Tags			任务终止
@Accept			application/json
@Produce		application/json
@Param			job	path		string	true	"任务id"
@Success		200	{object}	web.Response
@Router			/api/async/v0/job/{job}/terminate [patch]