Documentation ¶
Index ¶
- type AutoConfig
- func (ac *AutoConfig) DeleteAutoFlow(name string)
- func (ac *AutoConfig) Flow() *model.FlowMeta
- func (ac *AutoConfig) GetSettings() map[string]model.Setting
- func (ac *AutoConfig) LoadFlowFromTemplate(name string) error
- func (ac *AutoConfig) SaveNewFlow() error
- func (ac *AutoConfig) SetSettings(settings map[string]model.Setting)
- type Flow
- func (fl *Flow) AddNode(node model.Node)
- func (fl *Flow) CleanupBeforeDelete()
- func (fl *Flow) GetContext() *model.Context
- func (fl *Flow) GetFlowState() string
- func (fl *Flow) GetFlowStats() *model.FlowStatsReport
- func (fl *Flow) GetNodeById(id model.NodeID) model.Node
- func (fl *Flow) IsNodeCurrentNode(nodeId model.NodeID) bool
- func (fl *Flow) IsNodeIdValid(currentNodeId model.NodeID, transitionNodeId model.NodeID) bool
- func (fl *Flow) IsNodeValid(node *model.MetaNode) bool
- func (fl *Flow) LoadAndConfigureAllNodes()
- func (fl *Flow) ReloadNodes(nodes []model.Node)
- func (fl *Flow) SendExclusionReport()
- func (fl *Flow) SendInclusionReport()
- func (fl *Flow) SetConnectorRegistry(resources *connector.Registry)
- func (fl *Flow) SetExternalLibsDir(path string)
- func (fl *Flow) SetNodes(nodes []model.Node)
- func (fl *Flow) SetStoragePath(path string)
- func (fl *Flow) Start() error
- func (fl *Flow) StartFlowInstance(reactorEvent model.ReactorEvent)
- func (fl *Flow) Stop() error
- func (fl *Flow) TerminateRunningInstances()
- type FlowListItem
- type ImportTemplateVars
- type Instance
- type Manager
- func (mg *Manager) AddMetaFlowToRegistry(flowMeta model.FlowMeta) error
- func (mg *Manager) BackupAll() error
- func (mg *Manager) ControlFlow(cmd string, flowId string) error
- func (mg *Manager) DeleteFlowFromRegistry(id string, cleanRegistry bool)
- func (mg *Manager) DeleteFlowFromStorage(id string)
- func (mg *Manager) FactoryReset() error
- func (mg *Manager) GenerateNewFlow() model.FlowMeta
- func (mg *Manager) GetConnectorRegistry() *connector.Registry
- func (mg *Manager) GetFlowById(id string) *Flow
- func (mg *Manager) GetFlowBySettings(settings map[string]model.Setting) *Flow
- func (mg *Manager) GetFlowFileNameById(id string) string
- func (mg *Manager) GetFlowList() []FlowListItem
- func (mg *Manager) GetGlobalContext() *model.Context
- func (mg *Manager) GetNewStream(Id string) model.MsgPipeline
- func (mg *Manager) ImportFlow(flowJsonDef []byte) error
- func (mg *Manager) LoadAllFlowsFromStorage() error
- func (mg *Manager) LoadFlowFromFile(fileName string) error
- func (mg *Manager) LoadFlowFromJson(flowJsonDef []byte) error
- func (mg *Manager) ReloadFlowFromStorage(id string) error
- func (mg *Manager) SaveFlowToStorage(id string) error
- func (mg *Manager) StartFlow(flowId string)
- func (mg *Manager) StopFlow(id string)
- func (mg *Manager) UpdateFlowFromBinJson(id string, flowJsonDef []byte) error
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 (*Flow) CleanupBeforeDelete ¶
func (fl *Flow) CleanupBeforeDelete()
func (*Flow) GetContext ¶
func (*Flow) GetFlowState ¶
func (*Flow) GetFlowStats ¶
func (fl *Flow) GetFlowStats() *model.FlowStatsReport
func (*Flow) IsNodeIdValid ¶
func (*Flow) LoadAndConfigureAllNodes ¶
func (fl *Flow) LoadAndConfigureAllNodes()
LoadAndConfigureAllNodes creates all nodes objects from FlowMeta definitions and configures node inbound streams .
func (*Flow) ReloadNodes ¶
func (*Flow) SendExclusionReport ¶
func (fl *Flow) SendExclusionReport()
func (*Flow) SendInclusionReport ¶
func (fl *Flow) SendInclusionReport()
func (*Flow) SetConnectorRegistry ¶
func (*Flow) SetExternalLibsDir ¶
func (*Flow) SetStoragePath ¶
func (*Flow) Start ¶
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) TerminateRunningInstances ¶ added in v0.14.0
func (fl *Flow) TerminateRunningInstances()
Terminating all running instance except 1 caller instance
type FlowListItem ¶
type ImportTemplateVars ¶ added in v1.0.1
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func (*Manager) AddMetaFlowToRegistry ¶ added in v0.14.0
func (*Manager) DeleteFlowFromRegistry ¶
func (*Manager) DeleteFlowFromStorage ¶
func (*Manager) FactoryReset ¶ added in v1.0.1
FactoryReset deletes all nodes and restarts tpflow
func (*Manager) GenerateNewFlow ¶
func (*Manager) GetConnectorRegistry ¶
func (*Manager) GetFlowById ¶
func (*Manager) GetFlowBySettings ¶ added in v1.0.1
func (*Manager) GetFlowFileNameById ¶
func (*Manager) GetFlowList ¶
func (mg *Manager) GetFlowList() []FlowListItem
func (*Manager) GetGlobalContext ¶
func (*Manager) GetNewStream ¶
func (mg *Manager) GetNewStream(Id string) model.MsgPipeline
func (*Manager) ImportFlow ¶
func (*Manager) LoadAllFlowsFromStorage ¶
func (*Manager) LoadFlowFromFile ¶
func (*Manager) LoadFlowFromJson ¶
func (*Manager) ReloadFlowFromStorage ¶
func (*Manager) SaveFlowToStorage ¶ added in v0.14.0
Click to show internal directories.
Click to hide internal directories.