subflow

README

flogo-subflow

This activity provides your flogo flow the ability to start a sub-flow.

Installation

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

Schema

The Input/Output schema is determined from the Input/Output metadata of the sub-flow that is being executed

Settings

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

}

Setting	Description
flowURI	The URI of the flow to execute

Configuration Examples

Simple

Configure a activity to execute "mysubflow" and set its input values to literals "1" and "2".

{
  "id": "RunSubFlow",
  "activity": {
    "ref": "github.com/TIBCOSoftware/flogo-contrib/activity/subflow",
    "settings" : {
      "flowURI" : "res://flow:mysubflow"
    },
    "input": { 
  	  "mappings":[
        { "type": "literal", "value": "1", "mapTo": "FlowIn1" },
        { "type": "literal", "value": "2", "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