Versions in this module Expand all Collapse all v0 v0.6.0 Nov 27, 2021 Changes in this version + type DoOpt func(o DoOpts) DoOpts + func ErrorHandler(h eq_queue.ErrorListener) DoOpt + func SingleThread() DoOpt + type DoOpts struct + ErrorHandler eq_queue.ErrorListener + SingleThread bool + func (z DoOpts) Apply(opts []DoOpt) DoOpts + type Sequence interface + Do func(exec func(s Stage), opts ...DoOpt) + DoThen func(exec func(s Stage), opts ...DoOpt) Sequence + func New(opt ...eq_queue.Opt) Sequence + type Stage interface + Define func(queueId string, f interface{}, ctx ...interface{}) + Get func(queueId string) eq_queue.Queue
Go to main page