flow

Documentation

Index

• Constants
• func SetExtensionProvider(provider ExtensionProvider)
• type ActionOptions
• type ExtensionProvider
• type Flavor
• type FlowAction
  • func (fa *FlowAction) Config() *action.Config
  • func (fa *FlowAction) Metadata() *action.Metadata
  • func (fa *FlowAction) Run(context context.Context, inputs []*data.Attribute, ...) error
• type FlowFactory
  • func (ff *FlowFactory) New(config *action.Config) action.Action

Constants

const (
	FLOW_REF = "github.com/TIBCOSoftware/flogo-contrib/action/flow"
)

Functions

func SetExtensionProvider

func SetExtensionProvider(provider ExtensionProvider)

Types

type ActionOptions

type ActionOptions struct {
	MaxStepCount int
	Record       bool
}

ActionOptions are the options for the FlowAction

type ExtensionProvider

type ExtensionProvider interface {
	GetFlowProvider() provider.Provider
	GetFlowModel() *model.FlowModel
	GetStateRecorder() instance.StateRecorder
	GetMapperFactory() definition.MapperFactory
	GetLinkExprManagerFactory() definition.LinkExprManagerFactory
	GetFlowTester() *tester.RestEngineTester
}

Provides the different extension points to the Flow Action

type Flavor

type Flavor struct {
	// The flow is embedded and uncompressed
	Flow json.RawMessage `json:"flow"`
	// The flow is a URI
	FlowCompressed json.RawMessage `json:"flowCompressed"`
	// The flow is a URI
	FlowURI json.RawMessage `json:"flowURI"`
}

type FlowAction

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

func (*FlowAction) Config

func (fa *FlowAction) Config() *action.Config

Config get the Action's config

func (*FlowAction) Metadata

func (fa *FlowAction) Metadata() *action.Metadata

Metadata get the Action's metadata

func (*FlowAction) Run

func (fa *FlowAction) Run(context context.Context, inputs []*data.Attribute, options map[string]interface{}, handler action.ResultHandler) error

Run implements action.Action.Run func (fa *FlowAction) Run(context context.Context, uri string, options interface{}, handler action.ResultHandler) error {

type FlowFactory

type FlowFactory struct{}

func (*FlowFactory) New

func (ff *FlowFactory) New(config *action.Config) action.Action