Versions in this module Expand all Collapse all v1 v1.0.2 Sep 22, 2023 Changes in this version + func GetDataResolver() resolve.CompositeResolver + func GetExprFactory() expression.Factory + func GetMapperFactory() mapper.Factory + func NewDefaultActivityOutputMapper(task *Task) mapper.Mapper + func SetExprFactory(factory expression.Factory) + func SetMapperFactory(factory mapper.Factory) + type ActivityConfig struct + Activity activity.Activity + Details *activity.Details + HostName string + IsLegacy bool + Logger log.Logger + Name string + func (ac *ActivityConfig) GetInputSchema(name string) schema.Schema + func (ac *ActivityConfig) GetOutput(name string) interface{} + func (ac *ActivityConfig) GetOutputSchema(name string) schema.Schema + func (ac *ActivityConfig) GetSetting(setting string) (val interface{}, exists bool) + func (ac *ActivityConfig) InputMapper() mapper.Mapper + func (ac *ActivityConfig) OutputMapper() mapper.Mapper + func (ac *ActivityConfig) Ref() string + type ActivityResolver struct + func (r *ActivityResolver) GetResolverInfo() *resolve.ResolverInfo + func (r *ActivityResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error) + type Definition struct + func NewDefinition(rep *DefinitionRep) (def *Definition, err error) + func (d *Definition) Cleanup() 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) GetTask(taskID string) *Task + func (d *Definition) Links() []*Link + func (d *Definition) Metadata() *metadata.IOMetadata + func (d *Definition) ModelID() string + func (d *Definition) Name() string + func (d *Definition) Reconfigure(config *resource.Config) error + func (d *Definition) Tasks() []*Task + type DefinitionRep struct + ErrorHandler *ErrorHandlerRep + ExplicitReply bool + Links []*LinkRep + Metadata *metadata.IOMetadata + ModelID string + Name string + Tasks []*TaskRep + type ErrorHandler struct + func (eh *ErrorHandler) GetTask(taskID string) *Task + func (eh *ErrorHandler) Tasks() []*Task + type ErrorHandlerRep struct + Links []*LinkRep + Tasks []*TaskRep + type ErrorResolver struct + func (r *ErrorResolver) GetResolverInfo() *resolve.ResolverInfo + func (r *ErrorResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error) + type FlowContextResolver struct + func (r *FlowContextResolver) GetResolverInfo() *resolve.ResolverInfo + func (r *FlowContextResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error) + type FlowResolver struct + func (r *FlowResolver) GetResolverInfo() *resolve.ResolverInfo + func (r *FlowResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error) + type IteratorResolver struct + func (*IteratorResolver) GetResolverInfo() *resolve.ResolverInfo + func (*IteratorResolver) Resolve(scope data.Scope, item string, field string) (interface{}, error) + type Link struct + func GetExpressionLinks(def *Definition) []*Link + func (link *Link) Expr() expression.Expr + func (link *Link) FromTask() *Task + func (link *Link) ID() int + func (link *Link) Label() string + 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 LinkRep struct + FromID string + Label string + Name string + ToID string + Type string + Value string + type LinkType int + const LtDependency + const LtError + const LtExprOtherwise + const LtExpression + const LtLabel + type LoopConfig struct + func (l *LoopConfig) Accumulate() bool + func (l *LoopConfig) ApplyOutputOnAccumulate() bool + func (l *LoopConfig) Condition() expression.Expr + func (l *LoopConfig) Delay() int + func (l *LoopConfig) GetIterateOn() interface{} + type Provider interface + GetFlow func(flowURI string) (*DefinitionRep, error) + type RetryOnError interface + Count func(scope data.Scope) (int, error) + Interval func(scope data.Scope) (int, error) + type Task struct + func (task *Task) ActivityConfig() *ActivityConfig + func (task *Task) FromLinks() []*Link + func (task *Task) ID() string + func (task *Task) IsScope() bool + func (task *Task) LoopConfig() *LoopConfig + func (task *Task) Name() string + func (task *Task) RetryOnErrConfig() RetryOnError + func (task *Task) SettingsMapper() mapper.Mapper + func (task *Task) String() string + func (task *Task) ToLinks() []*Link + func (task *Task) TypeID() string + type TaskRep struct + ActivityCfgRep *activity.Config + ID string + Name string + Settings map[string]interface{} + Type string
Go to main page