asyncjob

Feb 17, 2022

Changes in this version

+ type AsyncJob struct

+ func New() *AsyncJob

+ func (aj *AsyncJob) GetWorkers() int

+ func (aj *AsyncJob) OnProgress(onProgressFunc func(progress Progress)) *AsyncJob

+ func (aj *AsyncJob) Run(listener func(job Job) error, data interface{}) (err error)

+ func (aj *AsyncJob) SetWorkers(concurrency int) *AsyncJob

+ type Job struct

+ func (j Job) Data() interface{}

+ func (j Job) Index() int

+ type Progress struct

+ func (p Progress) Current() int

+ func (p Progress) EstimateTimeLeft() time.Duration

+ func (p Progress) String() string

+ func (p Progress) Total() int