Versions in this module Expand all Collapse all v1 v1.0.0 Jan 15, 2024 Changes in this version + const ModelName + func New() *model.FlowModel + func SortTaskEntries(entries []*model.TaskEntry) + type ArrayIterator struct + func NewArrayIterator(data []interface{}) *ArrayIterator + func (itx *ArrayIterator) HasNext() bool + func (itx *ArrayIterator) Index() int + func (itx *ArrayIterator) Key() interface{} + func (itx *ArrayIterator) Value() interface{} + type DoWhile struct + Index int + type DoWhileTaskBehavior struct + func (dw *DoWhileTaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + func (dw *DoWhileTaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + type FlowBehavior struct + func (fb *FlowBehavior) Done(ctx model.FlowContext) + func (fb *FlowBehavior) Resume(ctx model.FlowContext) (resumed bool) + func (fb *FlowBehavior) Start(ctx model.FlowContext) (started bool, taskEntries []*model.TaskEntry) + func (fb *FlowBehavior) StartErrorHandler(ctx model.FlowContext) (taskEntries []*model.TaskEntry) + func (fb *FlowBehavior) TaskDone(ctx model.FlowContext) (flowDone bool) + type IntIterator struct + func NewIntIterator(count int) *IntIterator + func (itx *IntIterator) HasNext() bool + func (itx *IntIterator) Index() int + func (itx *IntIterator) Key() interface{} + func (itx *IntIterator) Value() interface{} + type Iterator interface + HasNext func() bool + Index func() int + Key func() interface{} + Value func() interface{} + type IteratorTaskBehavior struct + func (tb *IteratorTaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + func (tb *IteratorTaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + type ObjectIterator struct + func NewObjectIterator(data map[string]interface{}) *ObjectIterator + func (itx *ObjectIterator) HasNext() bool + func (itx *ObjectIterator) Index() int + func (itx *ObjectIterator) Key() interface{} + func (itx *ObjectIterator) Value() interface{} + type ReflectIterator struct + func NewReflectIterator(val reflect.Value) *ReflectIterator + func (itx *ReflectIterator) HasNext() bool + func (itx *ReflectIterator) Index() int + func (itx *ReflectIterator) Key() interface{} + func (itx *ReflectIterator) Value() interface{} + type RetryData struct + Count int + Interval int + type TaskBehavior struct + func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, err error) + func (tb *TaskBehavior) Enter(ctx model.TaskContext) (enterResult model.EnterResult) + func (tb *TaskBehavior) Error(ctx model.TaskContext, err error) (handled bool, taskEntries []*model.TaskEntry) + func (tb *TaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + func (tb *TaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error) + func (tb *TaskBehavior) Skip(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, propagateSkip bool)
Go to main page