cronjob

Sep 7, 2025

Changes in this version

+ const PRIORITY

type CronJob

+ func (c *CronJob) CronEntryID() cron.EntryID

type CronJobSpec

+ Description string

+ Name string

type CronJobStatus

+ LatestRunAt *time.Time

+ LatestTaskId string

+ Message string

+ RefInstanceId int

+ Status STATUS

+ UpdateAt *time.Time

+ func (s *CronJobStatus) SetUpdateAt(v time.Time)

+ func (s *CronJobStatus) TableName() string

+ func (t *CronJobStatus) Failed(msg string)

type DescribeCronJobRequest

+ func NewDescribeCronJobRequest(id string) *DescribeCronJobRequest

+ type QUEUE_EVENT_TYPE string

+ const QUEUE_EVENT_TYPE_ADD

+ const QUEUE_EVENT_TYPE_DELETE

+ const QUEUE_EVENT_TYPE_UPDATE

+ type QueueEvent struct

+ CronJobId string

+ Type QUEUE_EVENT_TYPE

+ func NewQueueEvent() *QueueEvent

+ func (e *QueueEvent) Load(v []byte) error

+ func (e *QueueEvent) String() string

+ type STATUS string

+ const STATUS_DELETING

+ const STATUS_FAILED

+ const STATUS_PENDDING

+ const STATUS_RUNNING

+ const STATUS_STOPPED

+ const STATUS_UPDATING

Jul 12, 2025

Changes in this version

+ type CronJobStatus struct

+ Node string

Jul 12, 2025

Changes in this version

type CronJobSpec

+ Enabled *bool

+ func (t *CronJobSpec) GetEnabled() bool

type QueryCronJobRequest

+ Name string

Jul 12, 2025

Changes in this version

+ const APP_NAME

+ type CronJob struct

+ CreatedAt time.Time

+ Id string

+ RefInstanceId int

+ func NewCronJob(spec CronJobSpec) *CronJob

+ func (c *CronJob) TableName() string

+ type CronJobSpec struct

+ Cron string

+ func NewCronJobSpec(cron string, spec task.TaskSpec) *CronJobSpec

+ func (t *CronJobSpec) SetDescription(desc string) *CronJobSpec

+ func (t *CronJobSpec) SetName(name string) *CronJobSpec

+ type DeleteCronJobRequest struct

+ type DescribeCronJobRequest struct

+ Id string

+ type QueryCronJobRequest struct

+ func NewQueryCronJobRequest() *QueryCronJobRequest

+ type Service interface

+ AddCronJob func(context.Context, *CronJobSpec) (*CronJob, error)

+ DeleteCronJob func(context.Context, *DeleteCronJobRequest) (*CronJob, error)

+ DescribeCronJob func(context.Context, *DescribeCronJobRequest) (*CronJob, error)

+ QueryCronJob func(context.Context, *QueryCronJobRequest) (*types.Set[*CronJob], error)

+ UpdateCronJob func(context.Context, *UpdateCronJobRequest) (*CronJob, error)

+ func GetService() Service

+ type UpdateCronJobRequest struct