support

Documentation

Index

• Constants
• type BasicRemoteFlowProvider
  • func (*BasicRemoteFlowProvider) GetFlow(flowURI string) (*definition.DefinitionRep, error)
• type FlowEntry
• type FlowManager
  • func GetFlowManager() *FlowManager
  • func NewFlowManager(flowProvider definition.Provider) *FlowManager
  • func (fm *FlowManager) GetFlow(uri string) (*definition.Definition, error)
  • func (fm *FlowManager) GetResource(id string) interface{}
  • func (fm *FlowManager) LoadResource(config *resource.Config) error
• type FlowManagerOld
  • func NewFlowManagerOld() *FlowManagerOld
  • func (mgr *FlowManagerOld) AddCompressed(id string, newFlow string) error
  • func (mgr *FlowManagerOld) AddURI(id string, newUri string) error
  • func (mgr *FlowManagerOld) AddUncompressed(id string, newFlow []byte) error
  • func (mgr *FlowManagerOld) GetFlow(id string) (*definition.DefinitionRep, error)
• type Interceptor
  • func (pi *Interceptor) GetTaskInterceptor(taskID string) *TaskInterceptor
  • func (pi *Interceptor) Init()
• type Patch
  • func (pp *Patch) GetInputMapper(taskID string) data.Mapper
  • func (pp *Patch) GetOutputMapper(taskID string) data.Mapper
  • func (pp *Patch) GetPatch(taskID string) *TaskPatch
  • func (pp *Patch) Init()
• type TaskInterceptor
• type TaskPatch
  • func (tp *TaskPatch) InputMapper() data.Mapper
  • func (tp *TaskPatch) OutputMapper() data.Mapper

Constants

const (
	RESTYPE_FLOW = "flow"
)

Types

type BasicRemoteFlowProvider

type BasicRemoteFlowProvider struct {
}

func (*BasicRemoteFlowProvider) GetFlow

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

type FlowEntry

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

FlowEntry will contain either a compressed flow, an uncompressed flow or a flow uri

type FlowManager

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

func GetFlowManager

func GetFlowManager() *FlowManager

func NewFlowManager

func NewFlowManager(flowProvider definition.Provider) *FlowManager

func (*FlowManager) GetFlow

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

func (*FlowManager) GetResource

func (fm *FlowManager) GetResource(id string) interface{}

func (*FlowManager) LoadResource

func (fm *FlowManager) LoadResource(config *resource.Config) error

type FlowManagerOld

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

FlowManagerOld is a simple manager for flows

func NewFlowManagerOld

func NewFlowManagerOld() *FlowManagerOld

NewFlowManager creates a new FlowManagerOld

func (*FlowManagerOld) AddCompressed

func (mgr *FlowManagerOld) AddCompressed(id string, newFlow string) error

AddCompressed adds a compressed flow to the map of flow entries

func (*FlowManagerOld) AddURI

func (mgr *FlowManagerOld) AddURI(id string, newUri string) error

AddURI adds a uri flow to the map of flow entries

func (*FlowManagerOld) AddUncompressed

func (mgr *FlowManagerOld) AddUncompressed(id string, newFlow []byte) error

TODO add schema validation for flow AddUncompressed adds an uncompressed flow to the map of flow entries

func (*FlowManagerOld) GetFlow

func (mgr *FlowManagerOld) GetFlow(id string) (*definition.DefinitionRep, error)

GetFlow gets the specified embedded flow

type Interceptor

type Interceptor struct {
	TaskInterceptors []*TaskInterceptor `json:"tasks"`
	// contains filtered or unexported fields
}

Interceptor contains a set of task interceptor, this can be used to override runtime data of an instance of the corresponding Flow. This can be used to modify runtime execution of a flow or in test/debug for implementing mocks for tasks

func (*Interceptor) GetTaskInterceptor

func (pi *Interceptor) GetTaskInterceptor(taskID string) *TaskInterceptor

GetTaskInterceptor get the TaskInterceptor for the specified task (referred to by ID)

func (*Interceptor) Init

func (pi *Interceptor) Init()

Init initializes the FlowInterceptor, usually called after deserialization

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) data.Mapper

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

func (*Patch) GetOutputMapper

func (pp *Patch) GetOutputMapper(taskID string) data.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 TaskInterceptor

type TaskInterceptor struct {
	ID      string            `json:"id"`
	Skip    bool              `json:"skip,omitempty"`
	Inputs  []*data.Attribute `json:"inputs,omitempty"`
	Outputs []*data.Attribute `json:"outputs,omitempty"`
}

TaskInterceptor contains instance override information for a Task, such has attributes. Also, a 'Skip' flag can be enabled to inform the runtime that the task should not execute.

type TaskPatch

type TaskPatch struct {
	ID             string             `json:"id"`
	Attributes     []*data.Attribute  `json:"attributes"`
	InputMappings  []*data.MappingDef `json:"inputMappings"` //put in mapper object
	OutputMappings []*data.MappingDef `json:"ouputMappings"` //put in mapper object

	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() data.Mapper

InputMapper returns the overriding InputMapper

func (*TaskPatch) OutputMapper

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

OutputMapper returns the overriding OutputMapper