support

package

v1.6.23 Latest Latest Go to latest Published: Dec 7, 2025 License: BSD-3-Clause Imports: 18 Imported by: 0

Details

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

Repository

github.com/project-flogo/flow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetAppName() string
func GetAppVerison() string
func GetDefinition(flowURI string) (*definition.Definition, bool, error)
func GetHostId() string
func GetPrioritizeExprTask() bool
func GetPropagateSkip() bool
func GetUserName() string
func InitDefaultDefLookup(fManager *FlowManager, rManager *resource.Manager)
func SetResource(resources []*resource.Config) error
type BasicRemoteFlowProvider
- func (fp *BasicRemoteFlowProvider) GetFlow(flowURI string) (*definition.DefinitionRep, error)
type FlowLoader
- func (*FlowLoader) LoadResource(config *resource.Config) (*resource.Resource, error)
type FlowManager
- func NewFlowManager(flowProvider definition.Provider) *FlowManager
- func (fm *FlowManager) GetFlow(uri string) (*definition.Definition, error)
type Patch
- func (pp *Patch) GetInputMapper(taskID string) mapper.Mapper
- func (pp *Patch) GetOutputMapper(taskID string) mapper.Mapper
- func (pp *Patch) GetPatch(taskID string) *TaskPatch
- func (pp *Patch) Init()
type TaskPatch
- func (tp *TaskPatch) InputMapper() mapper.Mapper
- func (tp *TaskPatch) OutputMapper() mapper.Mapper

Constants ¶

View Source

const (
	UserName   = "FLOGO_APP_USERNAME"
	HostName   = "FLOGO_HOST_NAME"
	AppName    = "FLOGO_APP_NAME"
	AppVersion = "FLOGO_APP_VERSION"

	PropagateSkip             = "FLOGO_TASK_PROPAGATE_SKIP"
	PropagateSkipDefault bool = true

	PrioritizeExprLink             = "FLOGO_TASK_PRIORITIZE_EXPR_LINK"
	PrioritizeExprLinkDefault bool = false
)

View Source

const (
	ResTypeFlow = "flow"
)

Variables ¶

This section is empty.

Functions ¶

func GetAppName ¶ added in v1.6.0

func GetAppName() string

func GetAppVerison ¶ added in v1.6.0

func GetAppVerison() string

func GetDefinition ¶

func GetDefinition(flowURI string) (*definition.Definition, bool, error)

func GetHostId ¶ added in v1.6.0

func GetHostId() string

func GetPrioritizeExprTask ¶ added in v1.6.5

func GetPrioritizeExprTask() bool

func GetPropagateSkip ¶ added in v1.6.4

func GetPropagateSkip() bool

func GetUserName ¶ added in v1.6.0

func GetUserName() string

func InitDefaultDefLookup ¶

func InitDefaultDefLookup(fManager *FlowManager, rManager *resource.Manager)

func SetResource ¶ added in v1.1.0

func SetResource(resources []*resource.Config) error

Types ¶

type BasicRemoteFlowProvider ¶

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

func (*BasicRemoteFlowProvider) GetFlow ¶

func (fp *BasicRemoteFlowProvider) GetFlow(flowURI string) (*definition.DefinitionRep, error)

type FlowLoader ¶

type FlowLoader struct {
}

func (*FlowLoader) LoadResource ¶

func (*FlowLoader) LoadResource(config *resource.Config) (*resource.Resource, error)

type FlowManager ¶

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

func NewFlowManager ¶

func NewFlowManager(flowProvider definition.Provider) *FlowManager

func (*FlowManager) GetFlow ¶

func (fm *FlowManager) GetFlow(uri string) (*definition.Definition, error)

type Patch ¶

type Patch struct {
	TaskPatches []*TaskPatch `json:"tasks"` //put in mapper object
	// contains filtered or unexported fields
}

Patch contains a set of task patches for a Flow Patch, this can be used to override the default data and mappings of a Flow

func (*Patch) GetInputMapper ¶

func (pp *Patch) GetInputMapper(taskID string) mapper.Mapper

GetInputMapper returns the InputMapper for the specified task (referred to by ID)

func (*Patch) GetOutputMapper ¶

func (pp *Patch) GetOutputMapper(taskID string) mapper.Mapper

GetOutputMapper returns the OutputMapper for the specified task (referred to by ID)

func (*Patch) GetPatch ¶

func (pp *Patch) GetPatch(taskID string) *TaskPatch

GetPatch returns the Task Patch for the specified task (referred to by ID)

func (*Patch) Init ¶

func (pp *Patch) Init()

Init initializes the FlowPatch, usually called after deserialization

type TaskPatch ¶

type TaskPatch struct {
	ID         string                 `json:"id"`
	Attributes []*data.Attribute      `json:"attributes"`
	Input      map[string]interface{} `json:"input"`
	Output     map[string]interface{} `json:"output"`

	Attrs map[string]*data.Attribute
	// contains filtered or unexported fields
}

TaskPatch contains patching information for a Task, such has attributes, input mappings, output mappings. This is used to override the corresponding settings for a Task in the Process

func (*TaskPatch) InputMapper ¶

func (tp *TaskPatch) InputMapper() mapper.Mapper

InputMapper returns the overriding InputMapper

func (*TaskPatch) OutputMapper ¶

func (tp *TaskPatch) OutputMapper() mapper.Mapper

OutputMapper returns the overriding OutputMapper

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
event
test

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