Versions in this module Expand all Collapse all v0 v0.5.1 Feb 1, 2018 Changes in this version + type FlowEntry struct + type FlowManager struct + func NewFlowManager() *FlowManager + func (mgr *FlowManager) AddCompressed(id string, newFlow string) error + func (mgr *FlowManager) AddURI(id string, newUri string) error + func (mgr *FlowManager) AddUncompressed(id string, newFlow []byte) error + func (mgr *FlowManager) GetFlow(id string) (*definition.DefinitionRep, error) + type Interceptor struct + TaskInterceptors []*TaskInterceptor + func (pi *Interceptor) GetTaskInterceptor(taskID string) *TaskInterceptor + func (pi *Interceptor) Init() + type Patch struct + TaskPatches []*TaskPatch + 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 struct + ID string + Inputs []*data.Attribute + Outputs []*data.Attribute + Skip bool + type TaskPatch struct + Attributes []*data.Attribute + Attrs map[string]*data.Attribute + ID string + InputMappings []*data.MappingDef + OutputMappings []*data.MappingDef + func (tp *TaskPatch) InputMapper() data.Mapper + func (tp *TaskPatch) OutputMapper() data.Mapper