Versions in this module Expand all Collapse all v1 v1.0.2 Sep 22, 2023 Changes in this version + const Activity + const AppName + const AppVersion + const Fail + const HostName + const Mocked + const NotExecuted + const Pass + const Primitive + const PrioritizeExprLink + const PrioritizeExprLinkDefault + const PropagateSkip + const PropagateSkipDefault + const ResTypeFlow + const UserName + func GetAppName() string + func GetAppVerison() string + func GetDefinition(flowURI string) (*definition.Definition, bool, error) + func GetHostId() string + func GetPrioritizeExprTask() bool + func GetPropagateSkip() bool + func GetUserName() string + func InitDefaultDefLookup(fManager *FlowManager, rManager *resource.Manager) + func SetResource(resources []*resource.Config) error + type Assertion struct + Expression interface{} + ID string + Message string + Name string + Result int + Type int + type BasicRemoteFlowProvider struct + func (fp *BasicRemoteFlowProvider) GetFlow(flowURI string) (*definition.DefinitionRep, error) + type FlowLoader struct + func (*FlowLoader) LoadResource(config *resource.Config) (*resource.Resource, error) + type FlowManager struct + func NewFlowManager(flowProvider definition.Provider) *FlowManager + func (fm *FlowManager) GetFlow(uri string) (*definition.Definition, 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) mapper.Mapper + func (pp *Patch) GetOutputMapper(taskID string) mapper.Mapper + func (pp *Patch) GetPatch(taskID string) *TaskPatch + func (pp *Patch) Init() + type TaskInterceptor struct + Assertions []Assertion + ID string + Inputs map[string]interface{} + Message string + Outputs map[string]interface{} + Result int + Skip bool + type TaskPatch struct + Attributes []*data.Attribute + Attrs map[string]*data.Attribute + ID string + Input map[string]interface{} + Output map[string]interface{} + func (tp *TaskPatch) InputMapper() mapper.Mapper + func (tp *TaskPatch) OutputMapper() mapper.Mapper
Go to main page