tasks

Mar 8, 2024

Changes in this version

type Schedule

+ Format string

+ func (s *Schedule) Equal(other *Schedule) bool

type Scheduler

+ Publish func()

Dec 4, 2023

Changes in this version

type Schedule

+ RunCount uint32

+ func (s *Schedule) GetLastRun() *time.Time

Nov 17, 2023

Changes in this version

type Option

+ func WithPublisher(publisher Publisher) Option

+ type Publisher interface

+ Publish func(task Task)

type Scheduler

+ List func() []Task

+ SetPublisher func(Publisher) Scheduler

type Task

+ IsRunning func() bool

+ Publish func()

+ SetPublisher func(Publisher) Task

Nov 1, 2023

Changes in this version

+ var TimeNow = time.Now

type Option

+ func WithID(id string) Option

+ func WithRunTimeout(runTimeout time.Duration) Option

+ type Schedule struct

+ Interval uint64

+ LastRunAt *time.Time

+ NextRunAt time.Time

+ StartDay time.Weekday

+ Unit TimeUnit

+ func ParseSchedule(format string) (*Schedule, error)

+ func (j *Schedule) Duration() time.Duration

+ func (j *Schedule) ShouldRun() bool

+ func (j *Schedule) UpdateNextRun() time.Time

type Task

+ func New(s *Schedule, ops ...Option) Task

+ Schedule func() *Schedule

+ SetNextRun func(time.Duration) Task

Oct 3, 2023

Changes in this version

+ const DefaultRunTimeoutInterval

+ const DefaultTickerInterval

+ func SetGlobalLocation(newLocation *time.Location)

+ type Option interface

+ func WithTickerInterval(tickerInterval time.Duration) Option

+ type Scheduler interface

+ Add func(Task) Scheduler

+ Clear func()

+ Count func() int

+ Get func(id string) Task

+ IsRunning func() bool

+ Start func() error

+ Stop func() error

+ func NewScheduler(ops ...Option) Scheduler

+ type Task interface

+ Do func(taskName string, task interface{}, params ...interface{}) Task

+ Duration func() time.Duration

+ ID func() string

+ LastRunTime func() time.Time

+ Name func() string

+ NextScheduledTime func() time.Time

+ Run func() bool

+ RunCount func() uint32

+ ShouldRun func() bool

+ UpdateSchedule func(format string) error

+ func NewTask(format string) (Task, error)

+ func NewTaskAtIntervals(interval uint64, unit TimeUnit) Task

+ func NewTaskDaily(hour, minute int) Task

+ func NewTaskOnWeekday(startDay time.Weekday, hour, minute int) Task

+ func NewTaskWithID(id, format string) (Task, error)

+ type TimeUnit uint

+ const Days

+ const Hours

+ const Minutes

+ const Never

+ const Seconds

+ const Weeks