gotask

Jul 19, 2019

Changes in this version

+ func InitDebugLog()

Jul 18, 2019

Changes in this version

+ func TaskEach(fn func(name string, fn func(...interface{}) func(...interface{}) (err error)))

+ func TaskGet(name string) func(...interface{}) func(...interface{}) (err error)

+ func TaskMatch(name string) bool

+ func TaskRegister(name string, fn interface{})

+ type Stat struct

+ CurDur float64

+ MaxDur float64

+ MaxQ int

+ QL int

type Task

+ func (t *Task) CurSize() int

+ func (t *Task) Size() int

Jul 4, 2019

Changes in this version

+ func GetTask(name string) (tsk *internal.TaskFnDef)

+ func GetTasks() map[string]*internal.TaskFnDef

+ func TaskRegistry(name string, fn interface{})

type Task

+ func (t *Task) Stat() internal.Stat

Jun 20, 2019

Changes in this version

+ var Cfg = struct{ ... }

Jun 11, 2019

Changes in this version

type Task

+ func (t *Task) Len() int

May 21, 2019

Changes in this version

+ const Version

+ var Debug = true

+ type Task struct

+ func NewTask(max int, maxDur time.Duration) *Task

+ func (t *Task) Do(f TaskFn, args ...interface{}) error

+ func (t *Task) Wait()

+ type TaskFn func(args ...interface{}) *_taskFn

+ func TaskOf(fn interface{}, efn ...func(err error)) TaskFn