timer

type Cron ¶

type Cron struct {
	Timer
}

Cron

func NewCron(t *timewheel.Timer, cb func(), name string, onClose func(timer *timewheel.Timer)) *Cron

func (c *Cron) Close()

func (c *Cron) Do()

type CronExpr ¶

type CronExpr struct {
	// contains filtered or unexported fields
}

Field name | Mandatory? | Allowed values | Allowed special characters ---------- | ---------- | -------------- | -------------------------- Seconds | No | 0-59 | * / , - Minutes | Yes | 0-59 | * / , - Hours | Yes | 0-23 | * / , - Day of month | Yes | 1-31 | * / , - Month | Yes | 1-12 | * / , - Day of week | Yes | 0-6 | * / , -

func NewCronExpr(expr string) (cronExpr *CronExpr, err error)

func (e *CronExpr) Next(t time.Time) time.Time

type Dispatcher ¶

type Dispatcher struct {
	ChanTimer chan *timewheel.Timer
}

one dispatcher per goroutine (goroutine not safe)

func NewDispatcher(l int) *Dispatcher

func (disp *Dispatcher) AfterFunc(d time.Duration, cb func(), onCloseTimer func(timer *timewheel.Timer), onAddTimer func(timer *timewheel.Timer)) *Timer

func (disp *Dispatcher) CronFunc(cronExpr *CronExpr, cb func(), onCloseTimer func(timer *timewheel.Timer), onAddTimer func(timer *timewheel.Timer)) *Cron

func (disp *Dispatcher) TickerFunc(d time.Duration, cb func(), onCloseTimer func(timer *timewheel.Timer), onAddTimer func(timer *timewheel.Timer)) *Ticker

type ITime ¶

type ITime interface {
	Close()
	Do()
	GetName() string
}

type Ticker ¶

type Ticker struct {
	Timer
}

Ticker

func NewTicker(t *timewheel.Timer, cb func(), name string, onClose func(timer *timewheel.Timer)) *Ticker

func (tk *Ticker) Close()

func (tk *Ticker) Do()

type Timer ¶

type Timer struct {
	// contains filtered or unexported fields
}

Timer

func NewTimer(t *timewheel.Timer, cb func(), name string, onClose func(timer *timewheel.Timer)) *Timer

func (t *Timer) Close()

func (t *Timer) Do()

func (t *Timer) GetName() string