subflow

README

---

title: Subflow weight: 4619

Subflow

This activity allows you to start a subflow.

Installation

Flogo Web

This activity comes out of the box with the Flogo Web UI

Flogo CLI

flogo install github.com/TIBCOSoftware/flogo-contrib/activity/subflow

Schema

{
  "settings":[
    {
      "name": "flowURI",
      "type": "string",
      "required": true
    }
  ]
}

The Input/Output schema is determined from the Input/Output metadata of the subflow that is being executed

Settings

Setting	Required	Description
flowURI	True	The URI of the flow to execute

Examples

The below example executes "mysubflow" and set its input values to literals "foo" and "bar".

{
  "id": "RunSubFlow",
  "activity": {
    "ref": "github.com/TIBCOSoftware/flogo-contrib/activity/subflow",
    "settings" : {
      "flowURI" : "res://flow:mysubflow"
    },
    "input": { 
  	  "mappings":[
        { "type": "literal", "value": "foo", "mapTo": "FlowIn1" },
        { "type": "literal", "value": "bar", "mapTo": "FlowIn2" }
      ]
    }
  }
}

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type SubFlowActivity
  • func (a *SubFlowActivity) Eval(ctx activity.Context) (done bool, err error)
  • func (a *SubFlowActivity) IOMetadata(ctx activity.Context) (*data.IOMetadata, error)
  • func (a *SubFlowActivity) Metadata() *activity.Metadata

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new SubFlowActivity

Types

type SubFlowActivity

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

SubFlowActivity is an Activity that is used to start a sub-flow, can only be used within the context of an flow settings: {flowURI} input : {sub-flow's input} output: {sub-flow's output}

func (*SubFlowActivity) Eval

func (a *SubFlowActivity) Eval(ctx activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Invokes a REST Operation

func (*SubFlowActivity) IOMetadata

func (a *SubFlowActivity) IOMetadata(ctx activity.Context) (*data.IOMetadata, error)

func (*SubFlowActivity) Metadata

func (a *SubFlowActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata