behaviors

Documentation

Index

• type ArrayIterator
  • func NewArrayIterator(data []interface{}) *ArrayIterator
  • func (itx *ArrayIterator) HasNext() bool
  • func (itx *ArrayIterator) Key() interface{}
  • func (itx *ArrayIterator) Value() interface{}
• type Flow
  • func (fb *Flow) Done(ctx model.FlowContext)
  • func (fb *Flow) Resume(ctx model.FlowContext) (resumed bool)
  • func (fb *Flow) Start(ctx model.FlowContext) (started bool, taskEntries []*model.TaskEntry)
  • func (fb *Flow) StartErrorHandler(ctx model.FlowContext) (taskEntries []*model.TaskEntry)
  • func (fb *Flow) TaskDone(ctx model.FlowContext) (flowDone bool)
• type IntIterator
  • func NewIntIterator(count int) *IntIterator
  • func (itx *IntIterator) HasNext() bool
  • func (itx *IntIterator) Key() interface{}
  • func (itx *IntIterator) Value() interface{}
• type Iterator
• type IteratorTask
  • func (tb *IteratorTask) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *IteratorTask) 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) Key() interface{}
  • func (itx *ObjectIterator) Value() interface{}
• type ReflectIterator
  • func NewReflectIterator(val reflect.Value) *ReflectIterator
  • func (itx *ReflectIterator) HasNext() bool
  • func (itx *ReflectIterator) Key() interface{}
  • func (itx *ReflectIterator) Value() interface{}
• type Task
  • func (tb *Task) Done(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry, err error)
  • func (tb *Task) Enter(ctx model.TaskContext) (enterResult model.EnterResult)
  • func (tb *Task) Error(ctx model.TaskContext, err error) (handled bool, taskEntries []*model.TaskEntry)
  • func (tb *Task) Eval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *Task) PostEval(ctx model.TaskContext) (evalResult model.EvalResult, err error)
  • func (tb *Task) Skip(ctx model.TaskContext) (notifyFlow bool, taskEntries []*model.TaskEntry)

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) Key

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

func (*ArrayIterator) Value

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

type Flow

type Flow struct {
}

Flow implements model.FlowBehavior

func (*Flow) Done

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

Done implements model.Flow.Done

func (*Flow) Resume

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

Resume implements model.Flow.Resume

func (*Flow) Start

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

Start implements model.Flow.Start

func (*Flow) StartErrorHandler

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

StartErrorHandler implements model.Flow.StartErrorHandler

func (*Flow) TaskDone

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

TasksDone implements model.Flow.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) 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
	// contains filtered or unexported methods
}

type IteratorTask

type IteratorTask struct {
	Task
}

SimpleIteratorTask implements model.TaskBehavior

func (*IteratorTask) Eval

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

Eval implements model.TaskBehavior.Eval

func (*IteratorTask) PostEval

func (tb *IteratorTask) 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) 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) Key

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

func (*ReflectIterator) Value

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

type Task

type Task struct {
}

Task implements model.Task

func (*Task) Done

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

Done implements model.Task.Done

func (*Task) Enter

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

Enter implements model.Task.Enter

func (*Task) Error

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

Done implements model.Task.Error

func (*Task) Eval

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

Eval implements model.Task.Eval

func (*Task) PostEval

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

PostEval implements model.Task.PostEval

func (*Task) Skip

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

Done implements model.Task.Skip