eq_mould

Documentation

Index

• type ErrorListener
• type Mould
  • func New(mouldId string, s eq_bundle.Bundle, ehs []ErrorListener, f interface{}, ...) Mould
• type Opt
• type Opts
  • func (z Opts) Apply(opts []Opt) Opts

Types

type ErrorListener

type ErrorListener func(err error, mouldId, batchId string, p interface{})

type Mould

type Mould interface {
	// Enqueue data
	Pour(p interface{})

	// Process the data
	Process(b eq_bundle.Barrel)

	// With batchId
	Batch(batchId string) Mould

	// Mould identifier
	MouldId() string
}

func New

func New(mouldId string, s eq_bundle.Bundle, ehs []ErrorListener, f interface{}, opts Opts, ctx ...interface{}) Mould

type Opt

type Opt func(o Opts) Opts

type Opts

type Opts struct {
	Verbose bool `json:"verbose"`
}

func (Opts) Apply

func (z Opts) Apply(opts []Opt) Opts