Versions in this module Expand all Collapse all v0 v0.3.3 Aug 29, 2020 v0.3.1 Aug 28, 2020 Changes in this version + var ErrJobNotFoundWithTag = errors.New("no jobs found with given tag") + var ErrNotAFunction = errors.New("only functions can be schedule into the job queue") + var ErrNotScheduledWeekday = errors.New("job not scheduled weekly on a weekday") + var ErrParamsNotAdapted = errors.New("the number of params is not adapted") + var ErrPeriodNotSpecified = errors.New("unspecified job period") + var ErrTimeFormat = errors.New("time format error") + var ErrUnsupportedTimeFormat = errors.New("the given time format is not supported") + func SetLocker(l Locker) + type Job struct + func NewJob(interval uint64) *Job + func (j *Job) Err() error + func (j *Job) ScheduledAtTime() string + func (j *Job) ScheduledTime() time.Time + func (j *Job) Tag(t string, others ...string) + func (j *Job) Tags() []string + func (j *Job) Untag(t string) + func (j *Job) Weekday() (time.Weekday, error) + type Locker interface + Lock func(key string) (bool, error) + Unlock func(key string) error + type Scheduler struct + func NewScheduler(loc *time.Location) *Scheduler + func (s *Scheduler) At(t string) *Scheduler + func (s *Scheduler) ChangeLocation(newLocation *time.Location) + func (s *Scheduler) Clear() + func (s *Scheduler) Day() *Scheduler + func (s *Scheduler) Days() *Scheduler + func (s *Scheduler) Do(jobFun interface{}, params ...interface{}) (*Job, error) + func (s *Scheduler) Every(interval uint64) *Scheduler + func (s *Scheduler) Friday() *Scheduler + func (s *Scheduler) Hour() *Scheduler + func (s *Scheduler) Hours() *Scheduler + func (s *Scheduler) Jobs() []*Job + func (s *Scheduler) Len() int + func (s *Scheduler) Less(i, j int) bool + func (s *Scheduler) Lock() *Scheduler + func (s *Scheduler) Minute() *Scheduler + func (s *Scheduler) Minutes() *Scheduler + func (s *Scheduler) Monday() *Scheduler + func (s *Scheduler) Month(dayOfTheMonth int) *Scheduler + func (s *Scheduler) Months(dayOfTheMonth int) *Scheduler + func (s *Scheduler) NextRun() (*Job, time.Time) + func (s *Scheduler) Remove(j interface{}) + func (s *Scheduler) RemoveByReference(j *Job) + func (s *Scheduler) RemoveJobByTag(tag string) error + func (s *Scheduler) RunAll() + func (s *Scheduler) RunAllWithDelay(d int) + func (s *Scheduler) RunPending() + func (s *Scheduler) Saturday() *Scheduler + func (s *Scheduler) Scheduled(j interface{}) bool + func (s *Scheduler) Second() *Scheduler + func (s *Scheduler) Seconds() *Scheduler + func (s *Scheduler) SetTag(t []string) *Scheduler + func (s *Scheduler) StartAsync() chan struct{} + func (s *Scheduler) StartAt(t time.Time) *Scheduler + func (s *Scheduler) StartBlocking() + func (s *Scheduler) StartImmediately() *Scheduler + func (s *Scheduler) Stop() + func (s *Scheduler) Sunday() *Scheduler + func (s *Scheduler) Swap(i, j int) + func (s *Scheduler) Thursday() *Scheduler + func (s *Scheduler) Tuesday() *Scheduler + func (s *Scheduler) Wednesday() *Scheduler + func (s *Scheduler) Week() *Scheduler + func (s *Scheduler) Weekday(startDay time.Weekday) *Scheduler + func (s *Scheduler) Weeks() *Scheduler