simple

Documentation

Index

• Constants
• func New() *model.FlowModel
• func SortTaskEntries(entries []*model.TaskEntry)
• type ArrayIterator
  • 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
• type DoWhileTaskBehavior
  • 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
  • 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
  • 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
• type IteratorTaskBehavior
  • 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
  • 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
  • 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
• type TaskBehavior
  • 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)

Constants

const (
	ModelName = "AIflow-simple"
)

const PropagateSkip = true

Functions

func New

func New() *model.FlowModel

func SortTaskEntries

func SortTaskEntries(entries []*model.TaskEntry)

SortTaskEntries Sort by EnterCode, keeping original order or equal elements.

Types

type ArrayIterator

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

func NewArrayIterator

func NewArrayIterator(data []interface{}) *ArrayIterator

func (*ArrayIterator) HasNext

func (itx *ArrayIterator) HasNext() bool

func (*ArrayIterator) Index

func (itx *ArrayIterator) Index() int

func (*ArrayIterator) Key

func (itx *ArrayIterator) Key() interface{}

func (*ArrayIterator) Value

func (itx *ArrayIterator) Value() interface{}

type DoWhile

type DoWhile struct {
	Index int `json:"index"`
}

DoWhile struct

type DoWhileTaskBehavior

type DoWhileTaskBehavior struct {
	TaskBehavior
}

DoWhileTaskBehavior implements model.TaskBehavior

func (*DoWhileTaskBehavior) Eval

func (dw *DoWhileTaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

Eval implements model.TaskBehavior.Eval

func (*DoWhileTaskBehavior) PostEval

func (dw *DoWhileTaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

PostEval implements model.TaskBehavior.PostEval

type FlowBehavior

type FlowBehavior struct {
}

FlowBehavior implements model.FlowBehavior

func (*FlowBehavior) Done

func (fb *FlowBehavior) Done(ctx model.FlowContext)

Done implements model.FlowBehavior.Done

func (*FlowBehavior) Resume

func (fb *FlowBehavior) Resume(ctx model.FlowContext) (resumed bool)

Resume implements model.FlowBehavior.Resume

func (*FlowBehavior) Start

func (fb *FlowBehavior) Start(ctx model.FlowContext) (started bool, taskEntries []*model.TaskEntry)

Start implements model.FlowBehavior.Start

func (*FlowBehavior) StartErrorHandler

func (fb *FlowBehavior) StartErrorHandler(ctx model.FlowContext) (taskEntries []*model.TaskEntry)

StartErrorHandler implements model.FlowBehavior.StartErrorHandler

func (*FlowBehavior) TaskDone

func (fb *FlowBehavior) TaskDone(ctx model.FlowContext) (flowDone bool)

TasksDone implements model.FlowBehavior.TasksDone

type IntIterator

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

func NewIntIterator

func NewIntIterator(count int) *IntIterator

func (*IntIterator) HasNext

func (itx *IntIterator) HasNext() bool

func (*IntIterator) Index

func (itx *IntIterator) Index() int

func (*IntIterator) Key

func (itx *IntIterator) Key() interface{}

func (*IntIterator) Value

func (itx *IntIterator) Value() interface{}

type Iterator

type Iterator interface {
	Key() interface{}
	Value() interface{}

	HasNext() bool
	Index() int
	// contains filtered or unexported methods
}

type IteratorTaskBehavior

type IteratorTaskBehavior struct {
	TaskBehavior
}

SimpleIteratorTask implements model.TaskBehavior

func (*IteratorTaskBehavior) Eval

func (tb *IteratorTaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

Eval implements model.TaskBehavior.Eval

func (*IteratorTaskBehavior) PostEval

func (tb *IteratorTaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

PostEval implements model.TaskBehavior.PostEval

type ObjectIterator

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

func NewObjectIterator

func NewObjectIterator(data map[string]interface{}) *ObjectIterator

func (*ObjectIterator) HasNext

func (itx *ObjectIterator) HasNext() bool

func (*ObjectIterator) Index

func (itx *ObjectIterator) Index() int

func (*ObjectIterator) Key

func (itx *ObjectIterator) Key() interface{}

func (*ObjectIterator) Value

func (itx *ObjectIterator) Value() interface{}

type ReflectIterator

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

func NewReflectIterator

func NewReflectIterator(val reflect.Value) *ReflectIterator

func (*ReflectIterator) HasNext

func (itx *ReflectIterator) HasNext() bool

func (*ReflectIterator) Index

func (itx *ReflectIterator) Index() int

func (*ReflectIterator) Key

func (itx *ReflectIterator) Key() interface{}

func (*ReflectIterator) Value

func (itx *ReflectIterator) Value() interface{}

type RetryData

type RetryData struct {
	Count    int
	Interval int
}

RetryData type

type TaskBehavior

type TaskBehavior struct {
}

TaskBehavior implements model.TaskBehavior

func (*TaskBehavior) Done

func (tb *TaskBehavior) Done(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, err error)

Done implements model.TaskBehavior.Done

func (*TaskBehavior) Enter

func (tb *TaskBehavior) Enter(ctx model.TaskContext) (enterResult model.EnterResult)

Enter implements model.TaskBehavior.Enter

func (*TaskBehavior) Error

func (tb *TaskBehavior) Error(ctx model.TaskContext, err error) (handled bool, taskEntries []*model.TaskEntry)

Error implements model.TaskBehavior.Error

func (*TaskBehavior) Eval

func (tb *TaskBehavior) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

Eval implements model.TaskBehavior.Eval

func (*TaskBehavior) PostEval

func (tb *TaskBehavior) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)

PostEval implements model.TaskBehavior.PostEval

func (*TaskBehavior) Skip

func (tb *TaskBehavior) Skip(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, propagateSkip bool)

Skip implements model.TaskBehavior.Skip