Versions in this module Expand all Collapse all v0 v0.5.8 Jan 19, 2019 Changes in this version + func GetDataResolver() data.Resolver + func SetLinkExprManagerFactory(factory LinkExprManagerFactory) + func SetMapperFactory(factory MapperFactory) + type ActivityConfig struct + Activity activity.Activity + func (ac *ActivityConfig) GetInputAttr(attrName string) (attr *data.Attribute, exists bool) + func (ac *ActivityConfig) GetOutputAttr(attrName string) (attr *data.Attribute, exists bool) + func (ac *ActivityConfig) GetSetting(setting string) (attr *data.Attribute, exists bool) + func (ac *ActivityConfig) InputMapper() data.Mapper + func (ac *ActivityConfig) OutputMapper() data.Mapper + func (ac *ActivityConfig) Ref() string + type ActivityConfigRep struct + InputAttrs map[string]interface{} + Mappings *Mappings + OutputAttrs map[string]interface{} + Ref string + Settings map[string]interface{} + type BasicMapperFactory struct + func (mf *BasicMapperFactory) GetDefaultActivityOutputMapper(task *Task) data.Mapper + func (mf *BasicMapperFactory) GetDefaultTaskOutputMapper(task *Task) data.Mapper + func (mf *BasicMapperFactory) NewActivityInputMapper(task *Task, mapperDef *data.MapperDef) data.Mapper + func (mf *BasicMapperFactory) NewActivityOutputMapper(task *Task, mapperDef *data.MapperDef) data.Mapper + func (mf *BasicMapperFactory) NewMapper(mapperDef *MapperDef) data.Mapper + func (mf *BasicMapperFactory) NewTaskInputMapper(task *Task, mapperDef *MapperDef) data.Mapper + func (mf *BasicMapperFactory) NewTaskOutputMapper(task *Task, mapperDef *MapperDef) data.Mapper + type DefaultActivityOutputMapper struct + func (m *DefaultActivityOutputMapper) Apply(inputScope data.Scope, outputScope data.Scope) error + type DefaultTaskOutputMapper struct + func (m *DefaultTaskOutputMapper) Apply(inputScope data.Scope, outputScope data.Scope) error + type Definition struct + func NewDefinition(rep *DefinitionRep) (def *Definition, err error) + func (d *Definition) ExplicitReply() bool + func (d *Definition) GetAttr(attrName string) (attr *data.Attribute, exists bool) + func (d *Definition) GetErrorHandler() *ErrorHandler + func (d *Definition) GetLink(linkID int) *Link + func (d *Definition) GetLinkExprManager() LinkExprManager + func (d *Definition) GetTask(taskID string) *Task + func (d *Definition) Links() []*Link + func (d *Definition) Metadata() *data.IOMetadata + func (d *Definition) ModelID() string + func (d *Definition) Name() string + func (d *Definition) SetLinkExprManager(mgr LinkExprManager) + func (d *Definition) Tasks() []*Task + type DefinitionRep struct + Attributes []*data.Attribute + ErrorHandler *ErrorHandlerRep + ErrorHandlerTask *TaskRepOld + ExplicitReply bool + Links []*LinkRep + Metadata *data.IOMetadata + ModelID string + Name string + RootTask *TaskRepOld + Tasks []*TaskRep + type DummyTaskCtx struct + func (*DummyTaskCtx) ActivityHost() activity.Host + func (*DummyTaskCtx) FlowDetails() activity.FlowDetails + func (*DummyTaskCtx) GetInitValue(key string) (value interface{}, exists bool) + func (*DummyTaskCtx) GetInput(name string) interface{} + func (*DummyTaskCtx) GetOutput(name string) interface{} + func (*DummyTaskCtx) GetSharedTempData() map[string]interface{} + func (*DummyTaskCtx) SetOutput(name string, value interface{}) + func (ctx *DummyTaskCtx) GetSetting(setting string) (value interface{}, exists bool) + func (ctx *DummyTaskCtx) Name() string + func (ctx *DummyTaskCtx) TaskName() string + type ErrorHandler struct + func (eh *ErrorHandler) Tasks() []*Task + type ErrorHandlerRep struct + Links []*LinkRep + Tasks []*TaskRep + type FlowResolver struct + func (r *FlowResolver) Resolve(toResolve string, scope data.Scope) (value interface{}, err error) + type Link struct + func GetExpressionLinks(def *Definition) []*Link + func (link *Link) FromTask() *Task + func (link *Link) ID() int + func (link *Link) String() string + func (link *Link) ToTask() *Task + func (link *Link) Type() LinkType + func (link *Link) Value() string + type LinkExprError struct + func NewLinkExprError(msg string) *LinkExprError + func (e *LinkExprError) Error() string + type LinkExprManager interface + EvalLinkExpr func(link *Link, scope data.Scope) (bool, error) + type LinkExprManagerFactory interface + NewLinkExprManager func() LinkExprManager + func GetLinkExprManagerFactory() LinkExprManagerFactory + type LinkRep struct + FromID string + Name string + ToID string + Type string + Value string + type LinkRepOld struct + FromID interface{} + ID int + Name string + ToID interface{} + Type int + Value string + type LinkType int + const LtDependency + const LtError + const LtExpression + const LtLabel + type MapperDef struct + Mappings []*data.MappingDef + type MapperFactory interface + GetDefaultActivityOutputMapper func(task *Task) data.Mapper + GetDefaultTaskOutputMapper func(task *Task) data.Mapper + NewActivityInputMapper func(task *Task, mapperDef *data.MapperDef) data.Mapper + NewActivityOutputMapper func(task *Task, mapperDef *data.MapperDef) data.Mapper + NewMapper func(mapperDef *MapperDef) data.Mapper + NewTaskInputMapper func(task *Task, mapperDef *MapperDef) data.Mapper + NewTaskOutputMapper func(task *Task, mapperDef *MapperDef) data.Mapper + func GetMapperFactory() MapperFactory + type Mappings struct + Input []*data.MappingDef + Output []*data.MappingDef + type Provider interface + GetFlow func(flowURI string) (*DefinitionRep, error) + type Task struct + func (task *Task) ActivityConfig() *ActivityConfig + func (task *Task) FromLinks() []*Link + func (task *Task) GetAttr(attrName string) (attr *data.Attribute, exists bool) + func (task *Task) GetInputAttr(attrName string) (attr *data.Attribute, exists bool) + func (task *Task) GetOutputAttr(attrName string) (attr *data.Attribute, exists bool) + func (task *Task) GetSetting(attrName string) (value interface{}, exists bool) + func (task *Task) ID() string + func (task *Task) IsScope() bool + func (task *Task) Name() string + func (task *Task) String() string + func (task *Task) ToLinks() []*Link + func (task *Task) TypeID() string + type TaskRep struct + ActivityCfgRep *ActivityConfigRep + ID string + Name string + Settings map[string]interface{} + Type string + type TaskRepOld struct + ActivityRef string + ActivityType string + Attributes []*data.Attribute + ID interface{} + InputAttrs map[string]interface{} + InputAttrsOld map[string]interface{} + InputMappings []*data.MappingDef + Links []*LinkRepOld + Mappings *Mappings + Name string + OutputAttrs map[string]interface{} + OutputAttrsOld map[string]interface{} + OutputMappings []*data.MappingDef + Settings map[string]interface{} + Tasks []*TaskRepOld + TypeID int
Go to main page