Documentation
¶
Index ¶
Constants ¶
View Source
const (
APP_NAME = "cronjobs"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronJob ¶
type CronJob struct {
// 任务Id
Id string `json:"id" gorm:"column:id;type:string;primary_key;" unique:"true" description:"Id"`
// 创建时间
CreatedAt time.Time `` /* 126-byte string literal not displayed */
// 关联的cron实例Id
RefInstanceId int `json:"ref_instance_id" gorm:"column:ref_instance_id;" description:"关联的cron实例Id"`
// Cronjob参数
CronJobSpec
}
func NewCronJob ¶
func NewCronJob(spec CronJobSpec) *CronJob
type CronJobSpec ¶
type CronJobSpec struct {
// Cron表达式
Cron string `json:"cron" gorm:"column:cron;type:varchar(120)" description:"Cron表达式"`
// Task执行参数
task.TaskSpec
}
func NewCronJobSpec ¶
func NewCronJobSpec(cron string, spec task.TaskSpec) *CronJobSpec
func (*CronJobSpec) SetDescription ¶
func (t *CronJobSpec) SetDescription(desc string) *CronJobSpec
func (*CronJobSpec) SetName ¶
func (t *CronJobSpec) SetName(name string) *CronJobSpec
type DeleteCronJobRequest ¶
type DeleteCronJobRequest struct {
DescribeCronJobRequest
}
type DescribeCronJobRequest ¶
type DescribeCronJobRequest struct {
// 任务Id
Id string `json:"id" description:"Id"`
}
type QueryCronJobRequest ¶
type QueryCronJobRequest struct {
*request.PageRequest
}
func NewQueryCronJobRequest ¶
func NewQueryCronJobRequest() *QueryCronJobRequest
type Service ¶
type Service interface {
// 添加CronJob
AddCronJob(context.Context, *CronJobSpec) (*CronJob, error)
// 查询列表
QueryCronJob(context.Context, *QueryCronJobRequest) (*types.Set[*CronJob], error)
// 查询详情
DescribeCronJob(context.Context, *DescribeCronJobRequest) (*CronJob, error)
// 更新Cronjob
UpdateCronJob(context.Context, *UpdateCronJobRequest) (*CronJob, error)
// 删除Cronjob
DeleteCronJob(context.Context, *DeleteCronJobRequest) (*CronJob, error)
}
func GetService ¶
func GetService() Service
type UpdateCronJobRequest ¶
type UpdateCronJobRequest struct {
}
Click to show internal directories.
Click to hide internal directories.