pipelinespliter

Documentation

Overview

* Copyright © 2020. TIBCO Software Inc. * This file is subject to the license terms contained * in the license file that is distributed with this file.

Index

• Constants
• func ActivityId(ctx activity.Context) string
• func NewActivity(metadata *activity.Metadata) activity.Activity
• type Contribute
• type Deployment
• type PipelineConfig
  • func (this *PipelineConfig) GetFlows() map[string]*definition.DefinitionRep
  • func (this *PipelineConfig) MarshalJSON() ([]byte, error)
  • func (this *PipelineConfig) MarshalResource() error
  • func (this *PipelineConfig) UnmarshalJSON(data []byte) error
  • func (this *PipelineConfig) UnmarshalResource() error
• type PipelineConfigSpliter
  • func CreatePipelineConfigSpliter(Template *PipelineConfig) *PipelineConfigSpliter
  • func (this *PipelineConfigSpliter) Split(aPipelineConfig *PipelineConfig) (*Deployment, error)
• type PipelineSpliterActivity
  • func (a *PipelineSpliterActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *PipelineSpliterActivity) Metadata() *activity.Metadata

Constants

const (
	ComponentType_External = "ext:app"
	ComponentType_Flogo    = "flogo:app"
)

Functions

func ActivityId

func ActivityId(ctx activity.Context) string

func NewActivity

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

Types

type Contribute

type Contribute struct {
	Ref      string `json:"ref"`
	Location string `json:"s3location"`
}

type Deployment

type Deployment struct {
	ID              string
	DataFlow        []interface{}
	PipelineConfigs []*PipelineConfig
}

type PipelineConfig

type PipelineConfig struct {
	app.Config
	//[{"ref":"git.tibco.com/git/product/ipaas/wi-contrib.git/contributions/General","s3location":"Tibco/General"},{"ref":"github.com/project-flogo/contrib/activity/log","s3location":"{USERID}/Default/activity/log"},{"ref":"github.com/TIBCOSoftware/GraphBuilder_Tools","s3location":"{USERID}/GraphBuilder_Tools"},{"ref":"github.com/TIBCOSoftware/ModelOps","s3location":"{USERID}/ModelOps"}]
	Contrib          map[string]Contribute
	Flows            map[string]*definition.DefinitionRep
	RunnerProperties map[string]interface{}
}

Def is the configuration for the App

func (*PipelineConfig) GetFlows

func (this *PipelineConfig) GetFlows() map[string]*definition.DefinitionRep

func (*PipelineConfig) MarshalJSON

func (this *PipelineConfig) MarshalJSON() ([]byte, error)

func (*PipelineConfig) MarshalResource

func (this *PipelineConfig) MarshalResource() error

func (*PipelineConfig) UnmarshalJSON

func (this *PipelineConfig) UnmarshalJSON(data []byte) error

func (*PipelineConfig) UnmarshalResource

func (this *PipelineConfig) UnmarshalResource() error

type PipelineConfigSpliter

type PipelineConfigSpliter struct {
	Template            *PipelineConfig
	GRPCTrigger         *trigger.Config
	GRPCJsonDeserialize *definition.TaskRep
	GRPCJsonSerialize   *definition.TaskRep
	GRPCCoupler         *definition.TaskRep
	GRPCReturn          *definition.TaskRep
	Metadata            *metadata.IOMetadata
	Schemas             map[string]*schema.Def
}

func CreatePipelineConfigSpliter

func CreatePipelineConfigSpliter(Template *PipelineConfig) *PipelineConfigSpliter

func (*PipelineConfigSpliter) Split

func (this *PipelineConfigSpliter) Split(aPipelineConfig *PipelineConfig) (*Deployment, error)

type PipelineSpliterActivity

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

func (*PipelineSpliterActivity) Eval

func (a *PipelineSpliterActivity) Eval(context activity.Context) (done bool, err error)

func (*PipelineSpliterActivity) Metadata

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