Versions in this module Expand all Collapse all v0 v0.6.0 Nov 27, 2021 Changes in this version + func ExecWithQueue(f func(q Definition)) + type Container interface + Get func(queueId string) (q Queue, found bool) + MustGet func(queueId string) Queue + Suspend func() (session eq_bundle.Session, err error) + Wait func() + type Definition interface + AddErrorListener func(h ErrorListener) + Current func() Container + Define func(queueId string, f interface{}, ctx ...interface{}) + Each func(f func(queueId string, f interface{}, ctx []interface{})) + Restore func(session eq_bundle.Session) (Container, error) + func New(opt ...Opt) Definition + type ErrorListener eq_mould.ErrorListener + type Opt func(o Opts) Opts + func AddErrorListener(eh eq_mould.ErrorListener) Opt + func Factory(f eq_pipe.Factory) Opt + func FetchPolicy(p eq_bundle.FetchPolicy) Opt + func Logger(l esl.Logger) Opt + func NumWorker(n int) Opt + func Progress(p eq_progress.Progress) Opt + func Verbose(enabled bool) Opt + type Opts struct + func (z Opts) Apply(opts ...Opt) Opts + type Queue interface + Batch func(batchId string) Queue + Enqueue func(p interface{})
Go to main page