flow

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AutoConfig added in v1.0.1 

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

func NewAutoConfig added in v1.0.1 

func NewAutoConfig(flowStorage string) *AutoConfig

func (*AutoConfig) DeleteAutoFlow added in v1.0.1 

func (ac *AutoConfig) DeleteAutoFlow(name string)

func (*AutoConfig) Flow added in v1.0.1 

func (ac *AutoConfig) Flow() *model.FlowMeta

func (*AutoConfig) GetSettings added in v1.0.1 

func (ac *AutoConfig) GetSettings() map[string]model.Setting

func (*AutoConfig) LoadFlowFromTemplate added in v1.0.1 

func (ac *AutoConfig) LoadFlowFromTemplate(name string) error

func (*AutoConfig) SaveNewFlow added in v1.0.1 

func (ac *AutoConfig) SaveNewFlow() error

func (*AutoConfig) SetSettings added in v1.0.1 

func (ac *AutoConfig) SetSettings(settings map[string]model.Setting)

type Flow 

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

	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) 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) StartFlowInstance added in v1.0.1 

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

T

func (*Flow) Stop 

func (fl *Flow) Stop() error

Terminates flow loop , stops goroutine .

func (*Flow) TerminateRunningInstances added in v0.14.0 

func (fl *Flow) TerminateRunningInstances()

Terminating all running instance except 1 caller instance

type FlowListItem 

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

type ImportTemplateVars added in v1.0.1 

type ImportTemplateVars struct {
	HubId  string
	SiteId string
}

type Instance added in v0.14.0 

type Instance struct {
	ID            int32
	CurrentNodeId model.NodeID
	StartNodeId   model.NodeID
	StartedAt     time.Time
}

type Manager 

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

func NewManager 

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

func (*Manager) AddMetaFlowToRegistry added in v0.14.0 

func (mg *Manager) AddMetaFlowToRegistry(flowMeta model.FlowMeta) error

func (*Manager) BackupAll added in v0.14.0 

func (mg *Manager) BackupAll() 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) FactoryReset added in v1.0.1 

func (mg *Manager) FactoryReset() error

FactoryReset deletes all nodes and restarts tpflow

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) GetFlowBySettings added in v1.0.1 

func (mg *Manager) GetFlowBySettings(settings map[string]model.Setting) *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) SaveFlowToStorage added in v0.14.0 

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

func (*Manager) StartFlow 

func (mg *Manager) StartFlow(flowId string)

func (*Manager) StopFlow 

func (mg *Manager) StopFlow(id string)

func (*Manager) UpdateFlowFromBinJson added in v0.14.0 

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

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.