Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronJobDAO ¶
type CronJobDAO interface {
CreateCronJob(ctx context.Context, job *model.CronJob) error
GetCronJob(ctx context.Context, id int) (*model.CronJob, error)
GetCronJobByName(ctx context.Context, name string) (*model.CronJob, error)
GetCronJobList(ctx context.Context, req *model.GetCronJobListReq) ([]*model.CronJob, int64, error)
UpdateCronJob(ctx context.Context, job *model.CronJob) error
DeleteCronJob(ctx context.Context, id int) error
UpdateCronJobStatus(ctx context.Context, id int, status model.CronJobStatus) error
UpdateCronJobRunInfo(ctx context.Context, id int, lastRunTime *time.Time, status int8, duration int, output, errorMsg string) error
GetEnabledCronJobs(ctx context.Context) ([]*model.CronJob, error)
UpdateNextRunTime(ctx context.Context, id int, nextRunTime time.Time) error
}
func NewCronJobDAO ¶
func NewCronJobDAO(logger *zap.Logger, db *gorm.DB) CronJobDAO
Click to show internal directories.
Click to hide internal directories.