scheduler

Jul 31, 2023

Changes in this version

+ type Context struct

+ Data interface{}

+ HandlerName string

+ ServiceName string

Jun 14, 2023

Changes in this version

type TimerManager

+ CloseTimer func()

+ TaskChan func() <-chan Task

Mar 13, 2023

Changes in this version

+ type ScheduleFunc func(_ *session.Session, _ interface{}, task Task)

Mar 13, 2023

Changes in this version

type Scheduler

+ func Global() Scheduler

Jan 28, 2023

Changes in this version

+ const Infinite

+ func Cron()

+ type Scheduler struct

+ func NewScheduler() *Scheduler

+ func (s *Scheduler) Close()

+ func (s *Scheduler) Digest()

+ func (s *Scheduler) PushTask(task Task)

+ func (s *Scheduler) Schedule(_ *session.Session, _ interface{}, task Task)

Nov 4, 2022

Changes in this version

+ type TimerManager struct

+ func NewTimerManager() *TimerManager

+ func (tm *TimerManager) Cron()

+ func (tm *TimerManager) NewAfterTimer(duration time.Duration, fn TimerFunc) *Timer

+ func (tm *TimerManager) NewCondTimer(condition TimerCondition, fn TimerFunc) *Timer

+ func (tm *TimerManager) NewCountTimer(interval time.Duration, count int, fn TimerFunc) *Timer

+ func (tm *TimerManager) NewTimer(interval time.Duration, fn TimerFunc) *Timer

Jun 28, 2021

Changes in this version

+ func Close()

+ func Digest()

+ func PushTask(task Task)

+ func Schedule(_ *session.Session, _ interface{}, task Task)

+ type SchedFunc func(session *session.Session, v interface{}, task Task)

+ type Task func()

+ type Timer struct

+ func NewAfterTimer(duration time.Duration, fn TimerFunc) *Timer

+ func NewCondTimer(condition TimerCondition, fn TimerFunc) *Timer

+ func NewCountTimer(interval time.Duration, count int, fn TimerFunc) *Timer

+ func NewTimer(interval time.Duration, fn TimerFunc) *Timer

+ func (t *Timer) ID() int64

+ func (t *Timer) Stop()

+ type TimerCondition interface

+ Check func(now time.Time) bool

+ type TimerFunc func()