eq_sequence

Documentation

Index

• type DoOpt
  • func ErrorHandler(h eq_queue.ErrorListener) DoOpt
  • func SingleThread() DoOpt
• type DoOpts
  • func (z DoOpts) Apply(opts []DoOpt) DoOpts
• type Sequence
  • func New(opt ...eq_queue.Opt) Sequence
• type Stage

Types

type DoOpt

type DoOpt func(o DoOpts) DoOpts

func ErrorHandler

func ErrorHandler(h eq_queue.ErrorListener) DoOpt

func SingleThread

func SingleThread() DoOpt

type DoOpts

type DoOpts struct {
	ErrorHandler eq_queue.ErrorListener
	SingleThread bool
}

func (DoOpts) Apply

func (z DoOpts) Apply(opts []DoOpt) DoOpts

type Sequence

type Sequence interface {
	// Do single stage
	Do(exec func(s Stage), opts ...DoOpt)

	// Do single stage, then returns next stage.
	DoThen(exec func(s Stage), opts ...DoOpt) Sequence
}

Batch sequence

func New

func New(opt ...eq_queue.Opt) Sequence

type Stage

type Stage interface {
	// Define function. This function must be called before Get.
	Define(queueId string, f interface{}, ctx ...interface{})

	// Get queue by id.
	Get(queueId string) eq_queue.Queue
}

Batch sequence stage: