simple

README

tibco-simple

This is a simple flow model.

Documentation

Index

• Constants
• func New() *model.FlowModel
• type ArrayIterator
  • func NewArrayIterator(data []interface{}) *ArrayIterator
  • func (itx *ArrayIterator) Key() interface{}
  • func (itx *ArrayIterator) Value() interface{}
• type IntIterator
  • func NewIntIterator(count int) *IntIterator
  • func (itx *IntIterator) Key() interface{}
  • func (itx *IntIterator) Value() interface{}
• type Iteration
• type Iterator
• type ObjectIterator
  • func NewObjectIterator(data map[string]interface{}) *ObjectIterator
  • func (itx *ObjectIterator) Key() interface{}
  • func (itx *ObjectIterator) Value() interface{}
• type SimpleFlowBehavior
  • func (pb *SimpleFlowBehavior) Done(context model.FlowContext)
  • func (pb *SimpleFlowBehavior) Resume(context model.FlowContext) bool
  • func (pb *SimpleFlowBehavior) Start(context model.FlowContext) (start bool, evalCode int)
  • func (pb *SimpleFlowBehavior) TasksDone(context model.FlowContext, doneCode int)
• type SimpleIteratorTaskBehavior
  • func (tb *SimpleIteratorTaskBehavior) ChildDone(context model.TaskContext, childTask *definition.Task, childDoneCode int) (done bool, doneCode int)
  • func (tb *SimpleIteratorTaskBehavior) Done(context model.TaskContext, doneCode int) (notifyParent bool, childDoneCode int, taskEntries []*model.TaskEntry, ...)
  • func (tb *SimpleIteratorTaskBehavior) Enter(context model.TaskContext, enterCode int) (eval bool, evalCode int)
  • func (tb *SimpleIteratorTaskBehavior) Error(context model.TaskContext) (handled bool, taskEntry *model.TaskEntry)
  • func (tb *SimpleIteratorTaskBehavior) Eval(context model.TaskContext, evalCode int) (evalResult model.EvalResult, doneCode int, err error)
  • func (tb *SimpleIteratorTaskBehavior) PostEval(context model.TaskContext, evalCode int, data interface{}) (done bool, doneCode int, err error)
• type SimpleTaskBehavior
  • func (tb *SimpleTaskBehavior) ChildDone(context model.TaskContext, childTask *definition.Task, childDoneCode int) (done bool, doneCode int)
  • func (tb *SimpleTaskBehavior) Done(context model.TaskContext, doneCode int) (notifyParent bool, childDoneCode int, taskEntries []*model.TaskEntry, ...)
  • func (tb *SimpleTaskBehavior) Enter(context model.TaskContext, enterCode int) (eval bool, evalCode int)
  • func (tb *SimpleTaskBehavior) Error(context model.TaskContext) (handled bool, taskEntry *model.TaskEntry)
  • func (tb *SimpleTaskBehavior) Eval(context model.TaskContext, evalCode int) (evalResult model.EvalResult, doneCode int, err error)
  • func (tb *SimpleTaskBehavior) PostEval(context model.TaskContext, evalCode int, data interface{}) (done bool, doneCode int, err error)

Constants

const (
	EC_SKIP = 1

	STATE_NOT_STARTED int = 0

	STATE_LINK_FALSE   int = 1
	STATE_LINK_TRUE    int = 2
	STATE_LINK_SKIPPED int = 3

	STATE_ENTERED int = 10
	STATE_READY   int = 20
	STATE_WAITING int = 30
	STATE_DONE    int = 40
	STATE_SKIPPED int = 50
	STATE_FAILED  int = 100
)

////////////////////////////////////////////////////////////////////////////////////////////////////// State

const (
	MODEL_NAME = "tibco-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) Key

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

func (*ArrayIterator) Value

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

type IntIterator

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

func NewIntIterator

func NewIntIterator(count int) *IntIterator

func (*IntIterator) Key

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

func (*IntIterator) Value

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

type Iteration

type Iteration struct {
	Key   interface{}
	Value interface{}
}

type Iterator

type Iterator interface {
	Key() interface{}
	Value() interface{}
	// contains filtered or unexported methods
}

type ObjectIterator

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

func NewObjectIterator

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

func (*ObjectIterator) Key

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

func (*ObjectIterator) Value

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

type SimpleFlowBehavior

type SimpleFlowBehavior struct {
}

SimpleFlowBehavior implements model.FlowBehavior

func (*SimpleFlowBehavior) Done

func (pb *SimpleFlowBehavior) Done(context model.FlowContext)

Done implements model.FlowBehavior.Done

func (*SimpleFlowBehavior) Resume

func (pb *SimpleFlowBehavior) Resume(context model.FlowContext) bool

Resume implements model.FlowBehavior.Resume

func (*SimpleFlowBehavior) Start

func (pb *SimpleFlowBehavior) Start(context model.FlowContext) (start bool, evalCode int)

Start implements model.FlowBehavior.Start

func (*SimpleFlowBehavior) TasksDone

func (pb *SimpleFlowBehavior) TasksDone(context model.FlowContext, doneCode int)

TasksDone implements model.FlowBehavior.TasksDone

type SimpleIteratorTaskBehavior

type SimpleIteratorTaskBehavior struct {
}

SimpleIteratorTaskBehavior implements model.TaskBehavior

func (*SimpleIteratorTaskBehavior) ChildDone

func (tb *SimpleIteratorTaskBehavior) ChildDone(context model.TaskContext, childTask *definition.Task, childDoneCode int) (done bool, doneCode int)

ChildDone implements model.TaskBehavior.ChildDone

func (*SimpleIteratorTaskBehavior) Done

func (tb *SimpleIteratorTaskBehavior) Done(context model.TaskContext, doneCode int) (notifyParent bool, childDoneCode int, taskEntries []*model.TaskEntry, err error)

Done implements model.TaskBehavior.Done

func (*SimpleIteratorTaskBehavior) Enter

func (tb *SimpleIteratorTaskBehavior) Enter(context model.TaskContext, enterCode int) (eval bool, evalCode int)

Enter implements model.TaskBehavior.Enter

func (*SimpleIteratorTaskBehavior) Error

func (tb *SimpleIteratorTaskBehavior) Error(context model.TaskContext) (handled bool, taskEntry *model.TaskEntry)

Done implements model.TaskBehavior.Error

func (*SimpleIteratorTaskBehavior) Eval

func (tb *SimpleIteratorTaskBehavior) Eval(context model.TaskContext, evalCode int) (evalResult model.EvalResult, doneCode int, err error)

Eval implements model.TaskBehavior.Eval

func (*SimpleIteratorTaskBehavior) PostEval

func (tb *SimpleIteratorTaskBehavior) PostEval(context model.TaskContext, evalCode int, data interface{}) (done bool, doneCode int, err error)

PostEval implements model.TaskBehavior.PostEval

type SimpleTaskBehavior

type SimpleTaskBehavior struct {
}

SimpleTaskBehavior implements model.TaskBehavior

func (*SimpleTaskBehavior) ChildDone

func (tb *SimpleTaskBehavior) ChildDone(context model.TaskContext, childTask *definition.Task, childDoneCode int) (done bool, doneCode int)

ChildDone implements model.TaskBehavior.ChildDone

func (*SimpleTaskBehavior) Done

func (tb *SimpleTaskBehavior) Done(context model.TaskContext, doneCode int) (notifyParent bool, childDoneCode int, taskEntries []*model.TaskEntry, err error)

Done implements model.TaskBehavior.Done

func (*SimpleTaskBehavior) Enter

func (tb *SimpleTaskBehavior) Enter(context model.TaskContext, enterCode int) (eval bool, evalCode int)

Enter implements model.TaskBehavior.Enter

func (*SimpleTaskBehavior) Error

func (tb *SimpleTaskBehavior) Error(context model.TaskContext) (handled bool, taskEntry *model.TaskEntry)

Done implements model.TaskBehavior.Error

func (*SimpleTaskBehavior) Eval

func (tb *SimpleTaskBehavior) Eval(context model.TaskContext, evalCode int) (evalResult model.EvalResult, doneCode int, err error)

Eval implements model.TaskBehavior.Eval

func (*SimpleTaskBehavior) PostEval

func (tb *SimpleTaskBehavior) PostEval(context model.TaskContext, evalCode int, data interface{}) (done bool, doneCode int, err error)

PostEval implements model.TaskBehavior.PostEval