Versions in this module Expand all Collapse all v0 v0.0.1 May 26, 2020 Changes in this version + const MODULE + var Missions *mission + type GoCron struct + func (g *GoCron) AddCronRecord(id cronV3.EntryID, s SchedulerInterface) error + func (g *GoCron) AddScheduler(s *Scheduler) error + func (g *GoCron) CheckCronRecord(s SchedulerInterface) (int, error) + func (g *GoCron) RemoveCronRecord(s SchedulerInterface) error + func (g *GoCron) RemoveScheduler(s *Scheduler) error + func (g *GoCron) Run() + func (g *GoCron) Stop() + type GoCronInterface interface + AddScheduler func(s *Scheduler) error + RemoveScheduler func(s *Scheduler) error + Run func() + Stop func() + func NewGoCron(redis orm.RedisClientInterface, opts ...cronV3.Option) GoCronInterface + type HttpHandler interface + CreateScheduler func(c *gin.Context) error + DeleteScheduler func(c *gin.Context) error + GetScheduler func(c *gin.Context) error + GetSchedulerList func(c *gin.Context) error + ModifyScheduler func(c *gin.Context) error + UpdateScheduler func(c *gin.Context) error + func NewSchedulerHttpHandler(gateway delivery.HttpHandler, svc Service) HttpHandler + type Repository interface + CreateScheduler func(data SchedulerInterface) (*Scheduler, error) + DeleteScheduler func(data SchedulerInterface) error + GetScheduler func(data SchedulerInterface) (*Scheduler, error) + GetSchedulerList func(data map[string]interface{}) ([]*Scheduler, error) + ModifyScheduler func(m SchedulerInterface, data map[string]interface{}) (*Scheduler, error) + UpdateScheduler func(data SchedulerInterface) (*Scheduler, error) + func NewSchedulerRepository(orm *gorm.DB) Repository + type Scheduler struct + CreateAt time.Time + ID int + Spec string + Task cronV3.Job + TaskName string + func (g *Scheduler) GetCreateAt() time.Time + func (g *Scheduler) GetID() int + func (g *Scheduler) GetSpec() string + func (g *Scheduler) GetTask() cronV3.Job + func (g *Scheduler) GetTaskName() string + func (g *Scheduler) SetCreateAt(in time.Time) *Scheduler + func (g *Scheduler) SetID(in int) *Scheduler + func (g *Scheduler) SetSpec(in string) *Scheduler + func (g *Scheduler) SetTask(in cronV3.Job) *Scheduler + func (g *Scheduler) SetTaskName(in string) *Scheduler + type SchedulerHttpHandler struct + func (g *SchedulerHttpHandler) CreateScheduler(c *gin.Context) error + func (g *SchedulerHttpHandler) DeleteScheduler(c *gin.Context) error + func (g *SchedulerHttpHandler) GetScheduler(c *gin.Context) error + func (g *SchedulerHttpHandler) GetSchedulerList(c *gin.Context) error + func (g *SchedulerHttpHandler) ModifyScheduler(c *gin.Context) error + func (g *SchedulerHttpHandler) UpdateScheduler(c *gin.Context) error + type SchedulerInterface interface + GetCreateAt func() time.Time + GetID func() int + GetSpec func() string + GetTask func() cronV3.Job + GetTaskName func() string + SetCreateAt func(in time.Time) *Scheduler + SetID func(in int) *Scheduler + SetSpec func(in string) *Scheduler + SetTask func(in cronV3.Job) *Scheduler + SetTaskName func(in string) *Scheduler + func NewScheduler() SchedulerInterface + type SchedulerLog struct + CreateAt time.Time + ID int + Scheduler *Scheduler + SchedulerID int + Success bool + func (g *SchedulerLog) GetCreateAt() time.Time + func (g *SchedulerLog) GetID() int + func (g *SchedulerLog) GetScheduler() *Scheduler + func (g *SchedulerLog) GetSchedulerID() int + func (g *SchedulerLog) IsSuccess() bool + func (g *SchedulerLog) SetCreateAt(in time.Time) *SchedulerLog + func (g *SchedulerLog) SetID(in int) *SchedulerLog + func (g *SchedulerLog) SetScheduler(in *Scheduler) *SchedulerLog + func (g *SchedulerLog) SetSchedulerID(in int) *SchedulerLog + func (g *SchedulerLog) SetSuccess(in bool) *SchedulerLog + type SchedulerLogInterface interface + GetCreateAt func() time.Time + GetID func() int + GetScheduler func() *Scheduler + GetSchedulerID func() int + IsSuccess func() bool + SetCreateAt func(in time.Time) *SchedulerLog + SetID func(in int) *SchedulerLog + SetScheduler func(in *Scheduler) *SchedulerLog + SetSchedulerID func(in int) *SchedulerLog + SetSuccess func(in bool) *SchedulerLog + func NewSchedulerLog() SchedulerLogInterface + type SchedulerRepository struct + func (s *SchedulerRepository) CreateScheduler(data SchedulerInterface) (*Scheduler, error) + func (s *SchedulerRepository) DeleteScheduler(data SchedulerInterface) error + func (s *SchedulerRepository) GetScheduler(data SchedulerInterface) (*Scheduler, error) + func (s *SchedulerRepository) GetSchedulerList(data map[string]interface{}) ([]*Scheduler, error) + func (s *SchedulerRepository) ModifyScheduler(m SchedulerInterface, data map[string]interface{}) (*Scheduler, error) + func (s *SchedulerRepository) UpdateScheduler(data SchedulerInterface) (*Scheduler, error) + type SchedulerService struct + func (s *SchedulerService) CreateScheduler(data SchedulerInterface) (*Scheduler, error) + func (s *SchedulerService) DeleteScheduler(data SchedulerInterface) error + func (s *SchedulerService) GetScheduler(data SchedulerInterface) (*Scheduler, error) + func (s *SchedulerService) GetSchedulerList(data map[string]interface{}) ([]*Scheduler, error) + func (s *SchedulerService) ModifyScheduler(m SchedulerInterface, data map[string]interface{}) (*Scheduler, error) + func (s *SchedulerService) UpdateScheduler(data SchedulerInterface) (*Scheduler, error) + type Service interface + CreateScheduler func(data SchedulerInterface) (*Scheduler, error) + DeleteScheduler func(data SchedulerInterface) error + GetScheduler func(data SchedulerInterface) (*Scheduler, error) + GetSchedulerList func(data map[string]interface{}) ([]*Scheduler, error) + ModifyScheduler func(m SchedulerInterface, data map[string]interface{}) (*Scheduler, error) + UpdateScheduler func(data SchedulerInterface) (*Scheduler, error) + func NewSchedulerService(core GoCronInterface, repo Repository) Service