pipeline

package

Go to main page

Versions in this module

v0

v0.3.0

Jan 23, 2020

Changes in this version

+ const ResTypeOld

type Definition

+ func (d *Definition) Id() string

type ExecutionContext

+ func (eCtx *ExecutionContext) GetTracingContext() trace.TracingContext

type Instance

+ func (inst *Instance) PipelineId() string

v0.2.1-rc.2

Nov 7, 2019

v0.2.1-rc.1

Sep 20, 2019

v0.2.0

May 14, 2019

Changes in this version

+ const ResType

+ func NewResourceLoader(mapperFactory mapper.Factory, resolver resolve.CompositeResolver) resource.Loader

type Definition

+ func (d *Definition) Cleanup() error

+ func (d *Definition) Name() string

type ExecutionContext

+ func (eCtx *ExecutionContext) GetInputObject(input data.StructValue) error

+ func (eCtx *ExecutionContext) Logger() log.Logger

+ func (eCtx *ExecutionContext) Scope() data.Scope

+ func (eCtx *ExecutionContext) SetOutputObject(output data.StructValue) error

type MultiScope

+ GetValueByScope func(scopeId ScopeId, name string) (value interface{}, exists bool)

+ type MultiScopeResolver struct

+ func (r *MultiScopeResolver) GetResolverInfo() *resolve.ResolverInfo

+ func (r *MultiScopeResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error)

+ type ResourceLoader struct

+ func (rl *ResourceLoader) LoadResource(config *resource.Config) (*resource.Resource, error)

+ type ScopeId int

+ const ScopeDefault

+ const ScopePassthru

+ const ScopePipeline

+ func (t ScopeId) String() string

type SharedScope

+ func (s *SharedScope) GetValue(name string) (value interface{}, exists bool)

+ func (s *SharedScope) SetValue(name string, value interface{}) error

type StageInputScope

+ func (s *StageInputScope) GetValue(name string) (value interface{}, exists bool)

+ func (s *StageInputScope) GetValueByScope(scopeId ScopeId, name string) (value interface{}, exists bool)

+ func (s *StageInputScope) SetValue(name string, value interface{}) error

type StageOutputScope

+ func (s *StageOutputScope) GetValue(name string) (value interface{}, exists bool)

+ func (s *StageOutputScope) GetValueByScope(scopeId ScopeId, name string) (value interface{}, exists bool)

+ func (s *StageOutputScope) SetValue(name string, value interface{}) error

v0.2.0-rc.2

May 9, 2019

v0.2.0-rc.1

May 2, 2019

v0.1.0

Sep 5, 2018

Changes in this version

+ const RESTYPE_PIPELINE

+ func ExecuteCurrentStage(ctx *ExecutionContext) (done bool, err error)

+ func GetDataResolver() data.Resolver

+ func NewSimpleScope(attrs []*data.Attribute, parentScope data.Scope) data.Scope

+ func Resume(ctx *ExecutionContext) error

+ func ResumeCurrentStage(ctx *ExecutionContext) (done bool, err error)

+ type BasicRemotePipelineProvider struct

+ func (*BasicRemotePipelineProvider) GetPipeline(pipelineURI string) (*DefinitionConfig, error)

+ type Definition struct

+ func NewDefinition(config *DefinitionConfig) (*Definition, error)

+ func (d *Definition) Metadata() *data.IOMetadata

+ type DefinitionConfig struct

+ Metadata *data.IOMetadata

+ Name string

+ Stages []*StageConfig

+ type DetailedAttribute struct

+ type ExecutionContext struct

+ func (eCtx *ExecutionContext) ActivityHost() activity.Host

+ func (eCtx *ExecutionContext) CancelTimer(repeating bool)

+ func (eCtx *ExecutionContext) CreateTimer(interval time.Duration, callback support.TimerCallback, repeating bool) error

+ func (eCtx *ExecutionContext) FlowDetails() activity.FlowDetails

+ func (eCtx *ExecutionContext) GetInitValue(key string) (value interface{}, exists bool)

+ func (eCtx *ExecutionContext) GetInput(name string) interface{}

+ func (eCtx *ExecutionContext) GetOutput(name string) interface{}

+ func (eCtx *ExecutionContext) GetResolver() data.Resolver

+ func (eCtx *ExecutionContext) GetSetting(setting string) (value interface{}, exists bool)

+ func (eCtx *ExecutionContext) GetSharedTempData() map[string]interface{}

+ func (eCtx *ExecutionContext) HasTimer(repeating bool) bool

+ func (eCtx *ExecutionContext) ID() string

+ func (eCtx *ExecutionContext) IOMetadata() *data.IOMetadata

+ func (eCtx *ExecutionContext) Name() string

+ func (eCtx *ExecutionContext) Reply(replyData map[string]*data.Attribute, err error)

+ func (eCtx *ExecutionContext) Return(returnData map[string]*data.Attribute, err error)

+ func (eCtx *ExecutionContext) SetOutput(name string, value interface{})

+ func (eCtx *ExecutionContext) Status() ExecutionStatus

+ func (eCtx *ExecutionContext) TaskName() string

+ func (eCtx *ExecutionContext) UpdateTimer(repeating bool)

+ func (eCtx *ExecutionContext) UpdateTimers()

+ func (eCtx *ExecutionContext) WorkingData() data.Scope

+ type ExecutionStatus int

+ const ExecStatusActive

+ const ExecStatusCancelled

+ const ExecStatusCompleted

+ const ExecStatusFailed

+ const ExecStatusNotStarted

+ const ExecStatusStalled

+ type InputValue interface

+ GetValue func(scope data.Scope) (*DetailedAttribute, error)

+ func NewInput(attrName string, attrType data.Type, resolver data.Resolver, value interface{}, ...) (InputValue, error)

+ type InputValues struct

+ func NewInputValues(inputMetadata map[string]*data.Attribute, resolver data.Resolver, ...) (*InputValues, error)

+ func (ivs *InputValues) GetAttrs(scope data.Scope) (map[string]*data.Attribute, error)

+ func (ivs *InputValues) GetDetailedAttrs(scope data.Scope) (map[string]*DetailedAttribute, error)

+ type Instance struct

+ func NewInstance(definition *Definition, id string, single bool, outChannel channels.Channel) *Instance

+ func (inst *Instance) DoStep(ctx *ExecutionContext, resume bool) (hasWork bool, err error)

+ func (inst *Instance) Id() string

+ func (inst *Instance) Run(discriminator string, input map[string]*data.Attribute) (output map[string]*data.Attribute, status ExecutionStatus, err error)

+ type Manager struct

+ func GetManager() *Manager

+ func NewManager() *Manager

+ func (m *Manager) GetPipeline(uri string) (*Definition, error)

+ func (m *Manager) GetResource(id string) interface{}

+ func (m *Manager) LoadResource(config *resource.Config) error

+ type MapperAlt interface

+ Apply func(inputScope data.Scope) (map[string]*data.Attribute, error)

+ type MultiScope interface

+ GetAttrByScope func(scope string, name string) (attr *data.Attribute, exists bool)

+ type Resolver struct

+ func (r *Resolver) Resolve(toResolve string, scope data.Scope) (value interface{}, err error)

+ type SharedScope struct

+ func (inst *SharedScope) AddAttr(attrName string, attrType data.Type, value interface{}) *data.Attribute

+ func (inst *SharedScope) GetAttr(attrName string) (value *data.Attribute, exists bool)

+ func (inst *SharedScope) SetAttrValue(attrName string, value interface{}) error

+ type SimpleScope struct

+ func NewSimpleScopeFromMap(attrs map[string]*data.Attribute, parentScope data.Scope) *SimpleScope

+ func (s *SimpleScope) AddAttr(name string, valueType data.Type, value interface{}) *data.Attribute

+ func (s *SimpleScope) GetAttr(name string) (attr *data.Attribute, exists bool)

+ func (s *SimpleScope) SetAttrValue(name string, value interface{}) error

+ type Stage struct

+ func NewStage(config *StageConfig) (*Stage, error)

+ type StageConfig struct

+ Promotions []string

+ type StageInputScope struct

+ func (s *StageInputScope) GetAttr(name string) (attr *data.Attribute, exists bool)

+ func (s *StageInputScope) GetAttrByScope(scope string, name string) (attr *data.Attribute, exists bool)

+ func (s *StageInputScope) SetAttrValue(name string, value interface{}) error

+ type StageOutputScope struct

+ func (s *StageOutputScope) GetAttr(name string) (attr *data.Attribute, exists bool)

+ func (s *StageOutputScope) GetAttrByScope(scope string, name string) (attr *data.Attribute, exists bool)

+ func (s *StageOutputScope) SetAttrValue(name string, value interface{}) error

+ type State interface

+ GetScope func() data.MutableScope

+ GetSharedData func(act activity.Activity) map[string]interface{}

+ GetTicker func(act activity.Activity) (*TickerHolder, bool)

+ GetTimer func(act activity.Activity) (*TimerHolder, bool)

+ NewTicker func(act activity.Activity, interval time.Duration) (*TickerHolder, error)

+ NewTimer func(act activity.Activity, interval time.Duration) (*TimerHolder, error)

+ RemoveTicker func(act activity.Activity) bool

+ RemoveTimer func(act activity.Activity) bool

+ type StateManager interface

+ GetState func(id string) State

+ func NewMultiStateManager() StateManager

+ func NewSimpleStateManager() StateManager

+ type Status int

+ const StatusActive

+ const StatusDone

+ const StatusNotStarted

+ type TickerHolder struct

+ func (t *TickerHolder) GetLastExecCtx() *ExecutionContext

+ func (t *TickerHolder) GetTicker() *time.Ticker

+ func (t *TickerHolder) SetLastExecCtx(ctx *ExecutionContext)

+ type TimerHolder struct

+ func (t *TimerHolder) GetLastExecCtx() *ExecutionContext

+ func (t *TimerHolder) GetTimer() *time.Timer

+ func (t *TimerHolder) SetLastExecCtx(ctx *ExecutionContext)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL