GoTask

package module

Go to main page

Versions in this module

v1

v1.0.15

Nov 20, 2021

Changes in this version

type ExecuteCbArgs

+ Gid pool.GoroutineUID

type ISchedule

+ AddExecuteCount func()

+ GetAddTime func() time.Time

+ GetExecuteCount func() int

type SpecSchedule

+ func (p *SpecSchedule) AddExecuteCount()

+ func (p *SpecSchedule) GetAddTime() time.Time

+ func (p *SpecSchedule) GetExecuteCount() int

type SpecTimeSchedule

+ func (p *SpecTimeSchedule) AddExecuteCount()

+ func (p *SpecTimeSchedule) GetAddTime() time.Time

+ func (p *SpecTimeSchedule) GetExecuteCount() int

type TaskInfo

+ Sche ISchedule

+ func (t *TaskInfo) GetExecuteCount() int

+ type TaskMap struct

+ func (tm *TaskMap) Add(key string, task *TaskInfo)

+ func (tm *TaskMap) AddOrSet(key string, task *TaskInfo)

+ func (tm *TaskMap) Delete(key string)

+ func (tm *TaskMap) Get(key string) *TaskInfo

+ func (tm *TaskMap) GetAll() map[string]*TaskInfo

+ func (tm *TaskMap) IsExist(key string) bool

+ func (tm *TaskMap) SelectNextExec() (*TaskInfo, time.Duration, bool)

+ func (tm *TaskMap) Set(key string, task *TaskInfo)

+ type TaskResult struct

+ Err error

+ Result map[string]interface{}

+ func (tr *TaskResult) Clone() *TaskResult

v1.0.14

Nov 20, 2021

v1.0.13

Nov 20, 2021

Changes in this version

+ type AddCbArgs struct

+ Error error

+ type BanCbArgs struct

+ Error error

+ Key string

+ type CancelCbArgs struct

+ Error error

+ Key string

+ type EveryDaySchedule struct

+ func NewEveryDaySchedule(hour, minute, second, mSecond int) *EveryDaySchedule

+ func (e *EveryDaySchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)

+ func (e *EveryDaySchedule) ToString() string

+ type ExecuteCbArgs struct

+ Error error

+ Res map[string]interface{}

+ type Func func() (map[string]interface{}, error)

+ type ISchedule interface

+ Expression func(t *TaskInfo) (nt time.Time, isValid bool)

+ ToString func() string

+ type Map struct

+ func NewTaskMap() *Map

+ func (tm *Map) Add(key string, task *TaskInfo)

+ func (tm *Map) AddOrSet(key string, task *TaskInfo)

+ func (tm *Map) Delete(key string)

+ func (tm *Map) Get(key string) *TaskInfo

+ func (tm *Map) GetAll() map[string]*TaskInfo

+ func (tm *Map) IsExist(key string) bool

+ func (tm *Map) SelectNextExec() (*TaskInfo, time.Duration, bool)

+ func (tm *Map) Set(key string, task *TaskInfo)

+ type PlanSchedule struct

+ func NewPlanSchedule(tList []time.Time) *PlanSchedule

+ func (p *PlanSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)

+ func (p *PlanSchedule) ToString() string

+ type Result struct

+ Err error

+ Result map[string]interface{}

+ func (tr *Result) Clone() *Result

+ type SpecSchedule struct

+ func NewSpecSchedule(spec time.Duration) *SpecSchedule

+ func (p *SpecSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)

+ func (p *SpecSchedule) Record(t *TaskInfo, cs ...int) (et []time.Time)

+ func (p *SpecSchedule) ToString() string

+ type SpecTimeSchedule struct

+ func NewSpecTimeSchedule(spec time.Duration, time int) *SpecTimeSchedule

+ func (p *SpecTimeSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)

+ func (p *SpecTimeSchedule) ToString() string

+ type TaskInfo struct

+ AddTime time.Time

+ Count int

+ HasNext bool

+ Key string

+ LastResult *Result

+ LastTime time.Time

+ NextTime time.Time

+ Schedule ISchedule

+ Task Func

+ func NewTaskInfo(key string, task Func, sche ISchedule) *TaskInfo

+ func (t *TaskInfo) Clone() *TaskInfo

+ func (t *TaskInfo) GetAddTaskTime() time.Time

+ func (t *TaskInfo) GetLastExecuteTime() (time.Time, bool)

+ func (t *TaskInfo) HasNextExecute() bool

+ func (t *TaskInfo) NextScheduleTime() time.Time

+ func (t *TaskInfo) Update()

+ type TimerObj func() (spec time.Duration, start, end time.Time)

+ func Timer() TimerObj

+ type UnBanCbArgs BanCbArgs

v1.0.12

Mar 19, 2021

v1.0.11

Mar 16, 2021

v1.0.10

Mar 16, 2021

v1.0.9

Mar 16, 2021

v1.0.8

Mar 16, 2021

v1.0.7

Mar 16, 2021

v1.0.6

Mar 8, 2021

Changes in this version

+ var ErrTaskIsBan = errors.New("task is ban")

+ var ErrTaskIsExist = errors.New("task is exist")

+ var ErrTaskIsNotExist = errors.New("task is not exist")

+ var ErrTaskIsUnBan = errors.New("task is already unban")

+ type CbFuncMap struct

+ func NewCbFuncMap() *CbFuncMap

+ func (fm *CbFuncMap) Add(i interface{})

+ func (fm *CbFuncMap) Del(i interface{})

+ func (fm *CbFuncMap) GetAll(out interface{}) int

+ type MultiTask struct

+ func NewMultiTask(routineCount int) *MultiTask

+ func (mt *MultiTask) Add(key string, t task.TaskObj, spec int, count int)

+ type SingleTask struct

+ func NewSingleTask(routineCount int) *SingleTask

+ func (st *SingleTask) Add(key string, task task.TaskObj, spec int)

+ type TimedTask struct

+ func NewTimedTask(maxRoutineCount int) *TimedTask

+ func (tt *TimedTask) Add(key string, obj task.TaskObj, sche task.ISchedule)

+ func (tt *TimedTask) AddAddCallback(cb func(*task.AddCbArgs))

+ func (tt *TimedTask) AddBanCallback(cb func(*task.BanCbArgs))

+ func (tt *TimedTask) AddCancelCallback(cb func(*task.CancelCbArgs))

+ func (tt *TimedTask) AddExecuteCallback(cb func(*task.ExecuteCbArgs))

+ func (tt *TimedTask) AddUnBanCallback(cb func(*task.UnBanCbArgs))

+ func (tt *TimedTask) Ban(key string)

+ func (tt *TimedTask) Cancel(key string)

+ func (tt *TimedTask) DelAddCallback(cb func(*task.AddCbArgs))

+ func (tt *TimedTask) DelBanCallback(cb func(*task.BanCbArgs))

+ func (tt *TimedTask) DelCancelCallback(cb func(*task.CancelCbArgs))

+ func (tt *TimedTask) DelExecuteCallback(cb func(*task.ExecuteCbArgs))

+ func (tt *TimedTask) DelUnBanCallback(cb func(*task.UnBanCbArgs))

+ func (tt *TimedTask) Execute(key string)

+ func (tt *TimedTask) GetTimedTaskInfo() map[string]*task.TaskInfo

+ func (tt *TimedTask) IsBan(key string) bool

+ func (tt *TimedTask) IsExist(key string) bool

+ func (tt *TimedTask) Set(key string, obj task.TaskObj, sche task.ISchedule)

+ func (tt *TimedTask) Stop()

+ func (tt *TimedTask) UnBan(key string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL