flow

Nov 3, 2022

Changes in this version

+ type Goroutine interface

+ Run func(ctx FlowContext) (r int, err error)

+ type GoroutineFlow struct

+ func NewGoroutineFlow() *GoroutineFlow

+ func (this *GoroutineFlow) AddFlow(flows ...Flow) *GoroutineFlow

+ func (this *GoroutineFlow) AddHook(hooks ...Hook) *GoroutineFlow

+ func (this *GoroutineFlow) AddPloy(ploys ...Ploy) *GoroutineFlow

+ func (this *GoroutineFlow) AddPloyFunc(fns ...func(ctx FlowContext)) *GoroutineFlow

+ func (this *GoroutineFlow) Run(ctx FlowContext)

+ func (this *GoroutineFlow) SetGoroutine(flowGoroutine Goroutine) (r *GoroutineFlow)

+ func (this *GoroutineFlow) SetGoroutineFunc(fn func(ctx FlowContext) (r int, err error)) (r *GoroutineFlow)

+ type GoroutineFunc func(ctx FlowContext) (r int, err error)

+ func (this GoroutineFunc) Run(ctx FlowContext) (r int, err error)

Apr 17, 2021

Changes in this version

type CoreContext

+ func (this *CoreContext) CleanErrors()

type FlowContext

+ CleanErrors func()

Apr 14, 2021

Changes in this version

+ const DEFAULT_SWITCH_RUNNABLE

Apr 14, 2021

Changes in this version

+ const DEFAULT_SWITCH_RUNNABLES

Aug 19, 2020

Changes in this version

+ var BreakError = errors.New("break error")

+ type Goto interface

+ Run func(ctx FlowContext) (r string, err error)

+ type GotoFlow struct

+ func NewGotoFlow() *GotoFlow

+ func (this *GotoFlow) AddFlow(cond string, flows ...Flow) *GotoFlow

+ func (this *GotoFlow) AddHook(hooks ...Hook) *GotoFlow

+ func (this *GotoFlow) AddPloy(cond string, ploys ...Ploy) *GotoFlow

+ func (this *GotoFlow) AddPloyFunc(cond string, fns ...func(ctx FlowContext)) *GotoFlow

+ func (this *GotoFlow) Run(ctx FlowContext)

+ func (this *GotoFlow) SetGoto(flowGoto Goto) (r *GotoFlow)

+ func (this *GotoFlow) SetGotoFunc(fn func(ctx FlowContext) (r string, err error)) (r *GotoFlow)

+ type GotoFunc func(ctx FlowContext) (r string, err error)

+ func (this GotoFunc) Run(ctx FlowContext) (r string, err error)

Jun 19, 2020

Changes in this version

+ type CommonFlow struct

+ func NewCommonFlow() *CommonFlow

+ func (this *CommonFlow) AddFlow(flow Flow)

+ func (this *CommonFlow) AddHook(hooks ...Hook)

+ func (this *CommonFlow) AddPloy(ploy Ploy)

+ type CoreContext struct

+ func (this *CoreContext) AddError(err error)

+ func (this *CoreContext) GetError() (r error)

+ func (this *CoreContext) GetErrors() (r []error)

+ func (this *CoreContext) HasError() (r bool)

+ func (this *CoreContext) Lock()

+ func (this *CoreContext) RLock()

+ func (this *CoreContext) RUnLock()

+ func (this *CoreContext) UnLock()

+ type Flow interface

+ type FlowContext interface

+ AddError func(err error)

+ GetError func() (r error)

+ GetErrors func() (r []error)

+ HasError func() (r bool)

+ Lock func()

+ RLock func()

+ RUnLock func()

+ UnLock func()

+ type Hook interface

+ After func(ctx FlowContext, runable Runnable)

+ Before func(ctx FlowContext, runable Runnable)

+ type ParallelFlow struct

+ func NewParallelFlow() *ParallelFlow

+ func (this *ParallelFlow) AddFlow(flow Flow) *ParallelFlow

+ func (this *ParallelFlow) AddHook(hooks ...Hook) *ParallelFlow

+ func (this *ParallelFlow) AddPloy(ploy Ploy) *ParallelFlow

+ func (this *ParallelFlow) AddPloyFunc(fn func(ctx FlowContext)) *ParallelFlow

+ func (this *ParallelFlow) Run(ctx FlowContext)

+ func (this *ParallelFlow) SetMaxProcess(num int) (r *ParallelFlow)

+ type PipeFlow struct

+ func New(hooks ...Hook) *PipeFlow

+ func NewPipeFlow() *PipeFlow

+ func (this *PipeFlow) AddFlow(flow Flow) *PipeFlow

+ func (this *PipeFlow) AddHook(hooks ...Hook) *PipeFlow

+ func (this *PipeFlow) AddPloy(ploy Ploy) *PipeFlow

+ func (this *PipeFlow) AddPloyFunc(fn func(ctx FlowContext)) *PipeFlow

+ func (this *PipeFlow) Run(ctx FlowContext)

+ type Ploy Runnable

+ type PloyFunc func(ctx FlowContext)

+ func (this PloyFunc) Run(ctx FlowContext)

+ type Runnable interface

+ Run func(ctx FlowContext)

+ type Switch interface

+ Run func(ctx FlowContext) (r string, err error)

+ type SwitchFlow struct

+ func NewSwitchFlow() *SwitchFlow

+ func (this *SwitchFlow) AddFlow(cond string, flow Flow) *SwitchFlow

+ func (this *SwitchFlow) AddHook(hooks ...Hook) *SwitchFlow

+ func (this *SwitchFlow) AddPloy(cond string, ploy Ploy) *SwitchFlow

+ func (this *SwitchFlow) AddPloyFunc(cond string, fn func(ctx FlowContext)) *SwitchFlow

+ func (this *SwitchFlow) Run(ctx FlowContext)

+ func (this *SwitchFlow) SetSwitch(flowSwitch Switch) (r *SwitchFlow)

+ func (this *SwitchFlow) SetSwitchFunc(fn func(ctx FlowContext) (r string, err error)) (r *SwitchFlow)

+ type SwitchFunc func(ctx FlowContext) (r string, err error)

+ func (this SwitchFunc) Run(ctx FlowContext) (r string, err error)