cronjobext

Apr 24, 2023

Changes in this version

+ type Config struct

+ AsyncTaskConfig *config.Config

+ BindTo string

+ HealthCheckPort int

+ TimeZone string

+ func (c *Config) TZ() (*time.Location, error)

+ type CronJobExt struct

+ NS string

+ TimeZone *time.Location

+ func (t *CronJobExt) Application() *gobay.Application

+ func (t *CronJobExt) Close() error

+ func (t *CronJobExt) Init(app *gobay.Application) error

+ func (t *CronJobExt) Object() interface{}

+ func (t *CronJobExt) RegisterTasks(ts map[string]*CronJobTask) error

+ func (t *CronJobExt) RemoveAllJobs()

+ func (t *CronJobExt) StartCronJob(enableHealthCheck bool)

+ type CronJobSchedulerType string

+ const CronScheduler

+ const DurationScheduler

+ type CronJobTask struct

+ Spec string

+ TaskFunc interface{}

+ TaskSignature *tasks.Signature

+ Type CronJobSchedulerType