flow

package

v0.12.10 Latest Latest Go to latest Published: Sep 23, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/thingsplex/tpflow

Links

Open Source Insights

Documentation ¶

Index ¶

type Flow
- func NewFlow(metaFlow model.FlowMeta, globalContext *model.Context) *Flow
type FlowListItem
type Manager
- func NewManager(config tpflow.Configs) (*Manager, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Flow ¶

type Flow struct {
	Id          string
	Name        string
	Description string
	FlowMeta    *model.FlowMeta

	//nodeOutboundStream  chan model.ReactorEvent
	//activeSubscriptions []string
	TriggerCounter    int64
	ErrorCounter      int64
	StartedAt         time.Time
	WaitingSince      time.Time
	LastExecutionTime time.Duration
	// contains filtered or unexported fields
}

func NewFlow ¶

func NewFlow(metaFlow model.FlowMeta, globalContext *model.Context) *Flow

func (*Flow) AddNode ¶

func (fl *Flow) AddNode(node model.Node)

func (*Flow) CleanupBeforeDelete ¶

func (fl *Flow) CleanupBeforeDelete()

func (*Flow) GetContext ¶

func (fl *Flow) GetContext() *model.Context

func (*Flow) GetFlowState ¶

func (fl *Flow) GetFlowState() string

func (*Flow) GetFlowStats ¶

func (fl *Flow) GetFlowStats() *model.FlowStatsReport

func (*Flow) GetNodeById ¶

func (fl *Flow) GetNodeById(id model.NodeID) model.Node

func (*Flow) IsNodeCurrentNode ¶

func (fl *Flow) IsNodeCurrentNode(nodeId model.NodeID) bool

func (*Flow) IsNodeIdValid ¶

func (fl *Flow) IsNodeIdValid(currentNodeId model.NodeID, transitionNodeId model.NodeID) bool

func (*Flow) IsNodeValid ¶

func (fl *Flow) IsNodeValid(node *model.MetaNode) bool

func (*Flow) LoadAndConfigureAllNodes ¶

func (fl *Flow) LoadAndConfigureAllNodes()

LoadAndConfigureAllNodes creates all nodes objects from FlowMeta definitions and configures node inbound streams .

func (*Flow) ReloadNodes ¶

func (fl *Flow) ReloadNodes(nodes []model.Node)

func (*Flow) Run ¶

func (fl *Flow) Run(reactorEvent model.ReactorEvent)

Invoked by trigger node in it's own goroutine

func (*Flow) SendExclusionReport ¶

func (fl *Flow) SendExclusionReport()

func (*Flow) SendInclusionReport ¶

func (fl *Flow) SendInclusionReport()

func (*Flow) SetConnectorRegistry ¶

func (fl *Flow) SetConnectorRegistry(resources *connector.Registry)

func (*Flow) SetExternalLibsDir ¶

func (fl *Flow) SetExternalLibsDir(path string)

func (*Flow) SetNodes ¶

func (fl *Flow) SetNodes(nodes []model.Node)

func (*Flow) SetStoragePath ¶

func (fl *Flow) SetStoragePath(path string)

func (*Flow) Start ¶

func (fl *Flow) Start() error

Starts Flow loop in its own goroutine and sets isFlowRunning flag to true Init sequence : STARTING -> RUNNING , STATING -> NOT_CONFIGURED ,

func (*Flow) Stop ¶

func (fl *Flow) Stop() error

Terminates flow loop , stops goroutine .

type FlowListItem ¶

type FlowListItem struct {
	Id             string
	Name           string
	Group          string
	Description    string
	State          string
	TriggerCounter int64
	ErrorCounter   int64
	Stats          *model.FlowStatsReport
}

type Manager ¶

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

func NewManager ¶

func NewManager(config tpflow.Configs) (*Manager, error)

func (*Manager) ControlFlow ¶

func (mg *Manager) ControlFlow(cmd string, flowId string) error

func (*Manager) DeleteFlowFromRegistry ¶

func (mg *Manager) DeleteFlowFromRegistry(id string, cleanRegistry bool)

func (*Manager) DeleteFlowFromStorage ¶

func (mg *Manager) DeleteFlowFromStorage(id string)

func (*Manager) GenerateNewFlow ¶

func (mg *Manager) GenerateNewFlow() model.FlowMeta

func (*Manager) GetConnectorRegistry ¶

func (mg *Manager) GetConnectorRegistry() *connector.Registry

func (*Manager) GetFlowById ¶

func (mg *Manager) GetFlowById(id string) *Flow

func (*Manager) GetFlowFileNameById ¶

func (mg *Manager) GetFlowFileNameById(id string) string

func (*Manager) GetFlowList ¶

func (mg *Manager) GetFlowList() []FlowListItem

func (*Manager) GetGlobalContext ¶

func (mg *Manager) GetGlobalContext() *model.Context

func (*Manager) GetNewStream ¶

func (mg *Manager) GetNewStream(Id string) model.MsgPipeline

func (*Manager) ImportFlow ¶

func (mg *Manager) ImportFlow(flowJsonDef []byte) error

func (*Manager) LoadAllFlowsFromStorage ¶

func (mg *Manager) LoadAllFlowsFromStorage() error

func (*Manager) LoadFlowFromFile ¶

func (mg *Manager) LoadFlowFromFile(fileName string) error

func (*Manager) LoadFlowFromJson ¶

func (mg *Manager) LoadFlowFromJson(flowJsonDef []byte) error

func (*Manager) ReloadFlowFromStorage ¶

func (mg *Manager) ReloadFlowFromStorage(id string) error

func (*Manager) StartFlow ¶

func (mg *Manager) StartFlow(flowId string)

func (*Manager) StopFlow ¶

func (mg *Manager) StopFlow(id string)

func (*Manager) UpdateFlowFromJson ¶

func (mg *Manager) UpdateFlowFromJson(id string, flowJsonDef []byte) error

func (*Manager) UpdateFlowFromJsonAndSaveToStorage ¶

func (mg *Manager) UpdateFlowFromJsonAndSaveToStorage(id string, flowJsonDef []byte) error

Source Files ¶

View all Source files

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