simple

Documentation

Index

• Constants
• func New() *model.FlowModel
• type ArrayIterator
  • func NewArrayIterator(data []interface{}) *ArrayIterator
  • func (itx *ArrayIterator) HasNext() bool
  • func (itx *ArrayIterator) Key() interface{}
  • func (itx *ArrayIterator) Value() interface{}
• 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) 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) Key() interface{}
  • func (itx *ObjectIterator) Value() interface{}
• 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)

Constants

const (
	MODEL_NAME = "flogo-simple"
)

Functions

func New

func New() *model.FlowModel

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

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

func (*ObjectIterator) Value

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

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)

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

Done implements model.TaskBehavior.Skip