scheduler

type Context ¶ added in v1.1.71

type Context struct {
	ServiceName string
	HandlerName string
	Data        interface{}
}

type ScheduleFunc ¶ added in v1.1.44

type ScheduleFunc func(*session.Session, *Context, Task)

type Scheduler ¶ added in v1.1.13

type Scheduler interface {
	TimerManager
	Schedule(*session.Session, *Context, Task)
	PushTask(task Task)
	Close()
}

func Global() Scheduler

type Task ¶

type Task = func()

Task is the unit to be scheduled

type Timer ¶

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

Timer represents a cron job

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 ¶

type TimerCondition interface {
	Check(now time.Time) bool
}

TimerCondition represents a checker that returns true when cron job needs to execute

type TimerFunc ¶

type TimerFunc func()

TimerFunc represents a function which will be called periodically in main logic gorontine.

type TimerManager ¶ added in v1.0.1

type TimerManager interface {
	NewCountTimer(interval time.Duration, count int, fn TimerFunc) *Timer
	NewAfterTimer(duration time.Duration, fn TimerFunc) *Timer
	NewCondTimer(condition TimerCondition, fn TimerFunc) *Timer
	NewTimer(interval time.Duration, fn TimerFunc) *Timer
	TaskChan() <-chan Task
	CloseTimer()
}

func NewTimerManager() TimerManager