Help us shape the future of Go! Take the 2026 Go Developer Survey

simple

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 15, 2024 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModelName = "flogo-simple"
)

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.