line

Documentation

Index

• Constants
• type Line
  • func Concurrent(to []*Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line
  • func Do(ts ...types.Transformer) *Line
  • func ErrLine() *Line
  • func Error(errL *Line, return0 bool) *Line
  • func If(f func(ctx types.ReqCtx) bool, l0 *Line) *Line
  • func New(name string) *Line
  • func Parallel(c int, mapF func(ctx types.ReqCtx) (ctxs []types.ReqCtx), to *Line, ...) *Line
  • func Switch(mapF func(ctx types.ReqCtx) string, to map[string]*Line) *Line
  • func (l *Line) Add(f func(*Line) *Line) *Line
  • func (l *Line) Concurrent(to []*Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line
  • func (l *Line) Do(ts ...types.Transformer) *Line
  • func (l *Line) Draw() (s string)
  • func (l *Line) Error(l0 *Line, return0 bool) *Line
  • func (l *Line) Func(f func(types.ReqCtx) types.ReqCtx) *Line
  • func (l *Line) If(f func(ctx types.ReqCtx) bool, l0 *Line) *Line
  • func (l *Line) Name() string
  • func (l *Line) NewCtx() types.ReqCtx
  • func (l *Line) Parallel(c int, mapF func(ctx types.ReqCtx) (ctxs []types.ReqCtx), to *Line, ...) *Line
  • func (l *Line) SetLog(b bool)
  • func (l *Line) Switch(mapF func(ctx types.ReqCtx) string, to map[string]*Line) *Line
  • func (l *Line) Transform(ctx types.ReqCtx) types.ReqCtx
• type Pipe
• type RequireCtx

Constants

const (
	Default = "default"
)

Types

type Line

type Line struct {
	Log bool
	// contains filtered or unexported fields
}

func Concurrent

func Concurrent(to []*Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line

func Do

func Do(ts ...types.Transformer) *Line

func ErrLine

func ErrLine() *Line

func Error

func Error(errL *Line, return0 bool) *Line

func If

func If(f func(ctx types.ReqCtx) bool, l0 *Line) *Line

func New

func New(name string) *Line

func Parallel

func Parallel(c int, mapF func(ctx types.ReqCtx) (ctxs []types.ReqCtx), to *Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line

func Switch

func Switch(mapF func(ctx types.ReqCtx) string, to map[string]*Line) *Line

func (*Line) Add

func (l *Line) Add(f func(*Line) *Line) *Line

func (*Line) Concurrent

func (l *Line) Concurrent(to []*Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line

func (*Line) Do

func (l *Line) Do(ts ...types.Transformer) *Line

func (*Line) Draw

func (l *Line) Draw() (s string)

func (*Line) Error

func (l *Line) Error(l0 *Line, return0 bool) *Line

func (*Line) Func

func (l *Line) Func(f func(types.ReqCtx) types.ReqCtx) *Line

func (*Line) If

func (l *Line) If(f func(ctx types.ReqCtx) bool, l0 *Line) *Line

func (*Line) Name

func (l *Line) Name() string

func (*Line) NewCtx

func (l *Line) NewCtx() types.ReqCtx

func (*Line) Parallel

func (l *Line) Parallel(c int, mapF func(ctx types.ReqCtx) (ctxs []types.ReqCtx), to *Line, reduceF func(ctx types.ReqCtx, ctxs []types.ReqCtx) types.ReqCtx) *Line

func (*Line) SetLog

func (l *Line) SetLog(b bool)

func (*Line) Switch

func (l *Line) Switch(mapF func(ctx types.ReqCtx) string, to map[string]*Line) *Line

func (*Line) Transform

func (l *Line) Transform(ctx types.ReqCtx) types.ReqCtx

type Pipe

type Pipe struct {
	Name string
	Func func(types.ReqCtx) types.ReqCtx
}

type RequireCtx

type RequireCtx struct {
	// contains filtered or unexported fields
}