model

package

Go to main page

Versions in this module

v1

v1.0.1

Oct 17, 2020

Changes in this version

type Context

+ func (ctx *Context) FactoryReset()

type FlowMeta

+ IsDefault bool

+ Settings map[string]Setting

type FlowOperationalContext

+ FlowMeta *FlowMeta

+ TriggerControlSignalChannel chan int

+ type Setting struct

+ Description string

+ InitVar bool

+ TVarPType string

+ TVarSType string

+ Value interface{}

+ ValueType string

+ func (s *Setting) String() string

v0

v0.14.0

Mar 3, 2020

Changes in this version

+ const ParallelExecutionKeepFirst

+ const ParallelExecutionKeepLast

+ const ParallelExecutionParallel

+ const SIGNAL_TERMINATE_WAITING

type FlowMeta

+ IsDisabled bool

+ ParallelExecution string

type ReactorEvent

+ SrcNodeId NodeID

v0.12.10

Sep 23, 2019

v0.12.3

Aug 3, 2019

Changes in this version

+ const SIGNAL_STOP

+ func GetValueByPath(msg *Message, pathType string, path string, targetVariableType string) (interface{}, error)

+ func MsgValueToNumber(msg *Message) (float64, error)

+ type Context struct

+ func NewContextDB(storageLocation string) (*Context, error)

+ func (ctx *Context) Close()

+ func (ctx *Context) DeleteRecord(name string, flowId string, inMemory bool) error

+ func (ctx *Context) GetRecord(name string, flowId string) (*ContextRecord, error)

+ func (ctx *Context) GetRecords(flowId string) []ContextRecord

+ func (ctx *Context) GetVariable(name string, flowId string) (Variable, error)

+ func (ctx *Context) GetVariableType(name string, flowId string) (string, error)

+ func (ctx *Context) PutRecord(rec *ContextRecord, flowId string, inMemory bool) error

+ func (ctx *Context) RegisterFlow(flowId string) error

+ func (ctx *Context) SetVariable(name string, valueType string, value interface{}, description string, ...) error

+ func (ctx *Context) UnregisterFlow(flowId string) error

+ type ContextInMemoryStore struct

+ func (ctx *ContextInMemoryStore) DeleteFlow(flowId string)

+ func (ctx *ContextInMemoryStore) Get(flowId string, varName string) *ContextRecord

+ func (ctx *ContextInMemoryStore) GetRecordsForFlow(flowId string) ([]ContextRecord, error)

+ func (ctx *ContextInMemoryStore) Store(rec ContextRecord, flowId string)

+ type ContextRecord struct

+ Description string

+ InMemory bool

+ Name string

+ UpdatedAt time.Time

+ Variable Variable

+ type FlowMeta struct

+ Author string

+ ClassId string

+ CreatedAt time.Time

+ Description string

+ Group string

+ Id string

+ Name string

+ Nodes []MetaNode

+ UpdatedAt time.Time

+ Version int

+ type FlowOperationalContext struct

+ ExtLibsDir string

+ FlowId string

+ IsFlowRunning bool

+ NodeControlSignalChannel chan int

+ NodeIsReady chan bool

+ State string

+ StoragePath string

+ type FlowRunner func(ReactorEvent)

+ type FlowStatsReport struct

+ CurrentNodeId NodeID

+ CurrentNodeLabel string

+ LastExecutionTime int64

+ NumberOfActiveSubflows int

+ NumberOfActiveTriggers int

+ NumberOfNodes int

+ NumberOfTriggers int

+ StartedAt time.Time

+ State string

+ WaitingSince time.Time

+ type Message struct

+ Address fimpgo.Address

+ AddressStr string

+ CancelOp bool

+ Header map[string]string

+ Payload fimpgo.FimpMessage

+ RawPayload []byte

+ type MetaNode struct

+ Address string

+ Config interface{}

+ ErrorTransition NodeID

+ Id NodeID

+ Label string

+ Service string

+ ServiceInterface string

+ SuccessTransition NodeID

+ TimeoutTransition NodeID

+ Type string

+ Ui interface{}

+ type MsgPipeline chan Message

+ type Node interface

+ Cleanup func() error

+ GetMetaNode func() *MetaNode

+ GetNextErrorNode func() NodeID

+ GetNextSuccessNodes func() []NodeID

+ GetNextTimeoutNode func() NodeID

+ Init func() error

+ IsMsgReactorNode func() bool

+ IsReactorRunning func() bool

+ IsStartNode func() bool

+ LoadNodeConfig func() error

+ OnInput func(msg *Message) ([]NodeID, error)

+ SetConnectorRegistry func(connectorRegistry *connector.Registry)

+ SetFlowRunner func(runner FlowRunner)

+ WaitForEvent func(responseChannel chan ReactorEvent)

+ type NodeID string

+ type ReactorEvent struct

+ Err error

+ Msg Message

+ TransitionNodeId NodeID

+ type Variable struct

+ Value interface{}

+ ValueType string

+ func (vrbl *Variable) IsEqual(var2 *Variable) (bool, error)

+ func (vrbl *Variable) IsNumber() bool

+ func (vrbl *Variable) ToNumber() (float64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL