Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronService ¶
type CronService interface {
CreateCronJob(ctx context.Context, req *model.CreateCronJobReq) error
UpdateCronJob(ctx context.Context, req *model.UpdateCronJobReq) error
DeleteCronJob(ctx context.Context, id int) error
GetCronJob(ctx context.Context, id int) (*model.CronJob, error)
GetCronJobList(ctx context.Context, req *model.GetCronJobListReq) (model.ListResp[*model.CronJob], error)
EnableCronJob(ctx context.Context, id int) error
DisableCronJob(ctx context.Context, id int) error
TriggerCronJob(ctx context.Context, id int) error
ValidateSchedule(ctx context.Context, req *model.ValidateScheduleReq) (*model.ValidateScheduleResp, error)
}
func NewCronService ¶
func NewCronService( logger *zap.Logger, cronDAO dao.CronJobDAO, userDAO userDao.UserDAO, client *asynq.Client, cronScheduler *scheduler.CronScheduler, ) CronService
Click to show internal directories.
Click to hide internal directories.