task

type AsyncRunner interface {
	// 触发异步执行
	Start(ctx context.Context, task *Task) error
	// 获取任务状态
	GetStatus(ctx context.Context, taskID string) (*TaskStatus, error)
	// 取消任务
	Cancel(ctx context.Context, taskID string) error
}

type CancelRequest struct {
	DescribeTaskRequest
}

type DescribeTaskRequest struct {
	TaskId string `json:"task_id"`
}

type QUEUE_EVENT_TYPE string

type QueryTaskRequest struct {
	request.PageRequest

	Label map[string]string `json:"label"`
}

type QueueEvent struct {
	// 事件类型
	Type QUEUE_EVENT_TYPE `json:"type"`
	// 事件值
	TaskId string `json:"task_id"`
}

type RUN_PARAM_TYPE string

type RunParam struct {
	// 参数类型
	Type RUN_PARAM_TYPE `json:"type" gorm:"column:run_param_type;type:varchar(60)" description:"参数类型"`
	// 参数值
	Value string `json:"value" gorm:"column:run_param_value;type:text" description:"参数值"`
}

type STATUS int

type Service interface {
	// 创建任务
	CreateTask(context.Context, *TaskSpec) (*Task, error)
	// 任务执行
	Run(context.Context, *TaskSpec) (*Task, error)
	// 任务取消
	Cancel(context.Context, *CancelRequest) (*Task, error)
	// 查询任务列表
	QueryTask(context.Context, *QueryTaskRequest) (*types.Set[*Task], error)
	// 查询任务详情
	DescribeTask(context.Context, *DescribeTaskRequest) (*Task, error)
}

type SyncRunner interface {
	// 同步执行，通过ctx控制取消
	Run(ctx context.Context, task *Task) error
}

type Task 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 */
	// 任务定义
	TaskSpec
	// 任务状态
	TaskStatus

	// 执行过程中的事件, 执行日志
	Events []*event.Event `json:"events" gorm:"-" description:"执行过程中的事件"`
}

type TaskFunc func(ctx context.Context, req any) error

type TaskSpec struct {
	// 任务Id
	TaskId string `json:"task_id" gorm:"-" description:"任务Id, 如果是任务Id,则查询任务执行"`
	// 异步执行时的超时时间
	Timeout string `json:"timeout" gorm:"column:timeout;" description:"异步执行时的超时时间"`
	// 尝试执行,用于做执行前检查
	Async bool `json:"async" gorm:"column:async;type:bool;" description:"是否是异步任务"`
	// 执行器名称
	Runner string `json:"runner" gorm:"column:type;type:varchar(60);" description:"执行器名称"`
	// 执行器参数
	Params *RunParam `json:"params" gorm:"embedded" description:"任务参数"`
	// 任务名称
	Name string `json:"name" gorm:"column:name;type:varchar(200);" description:"任务名称"`
	// 任务名称
	Description string `json:"description" gorm:"column:description;type:text;" description:"任务描述"`
	// 尝试执行,用于做执行前检查
	DryRun bool `json:"dryrun" gorm:"column:dryrun;type:bool;" description:"尝试执行,用于做执行前检查"`
	// 事件所属资源
	Resource string `json:"resource" gorm:"column:resource;type:varchar(120);" description:"事件所属资源"`
	// 任务标签
	Label map[string]string `json:"label" bson:"label" gorm:"column:label;serializer:json;type:json" description:"任务标签" optional:"true"`

	// 任务执行结束回调
	WebHooks []*webhook.WebHook `` /* 138-byte string literal not displayed */
}

type TaskStatus struct {
	// 开始执行时间
	StartAt *time.Time `json:"start_at" gorm:"column:start_at;type:timestamp;" description:"开始执行时间"`
	// 执行结束的时间
	EndAt *time.Time `json:"end_at" gorm:"column:end_at;type:timestamp;" description:"执行结束的时间"`
	// 任务状态更新时间
	UpdateAt *time.Time `json:"update_at" gorm:"column:update_at;type:timestamp;" description:"任务状态更新时间"`
	// 任务执行状态
	Status STATUS `json:"status" gorm:"column:status;type:tinyint(2);" description:"任务执行状态"`
	// 失败信息
	Message string `json:"message" gorm:"column:message;type:text;" description:"失败信息"`
	// 失败信息
	Detail string `json:"detail" gorm:"column:detail;type:text;" description:"详情内容"`
	// contains filtered or unexported fields
}

type UnimplementedAsyncRunner struct{}

type UnimplementedSyncRunner struct{}