instance

package

Go to main page

Versions in this module

v0

v0.5.9

Oct 27, 2020

v0.5.8

Jan 19, 2019

v0.5.8-rc1

Jan 4, 2019

v0.5.7

Nov 8, 2018

v0.5.7-rc2

Nov 2, 2018

v0.5.7-rc1

Oct 21, 2018

v0.5.6

Aug 13, 2018

Changes in this version

type TaskInst

+ func (ti *TaskInst) GetSharedTempData() map[string]interface{}

v0.5.5

Jun 26, 2018

v0.5.4

May 18, 2018

v0.5.3

Mar 29, 2018

Changes in this version

type Instance

+ func (inst *Instance) GetError() error

v0.5.3-rc1

Mar 29, 2018

v0.5.2

Mar 21, 2018

Changes in this version

+ func GetFlowIOMetadata(flowURI string) (*data.IOMetadata, error)

+ func StartSubFlow(ctx activity.Context, flowURI string, inputs map[string]*data.Attribute) error

type AttributeChange

+ SubFlowID int

+ type IndependentInstance struct

+ ChangeTracker *InstanceChangeTracker

+ func NewIndependentInstance(instanceID string, flowURI string, flow *definition.Definition) *IndependentInstance

+ func (inst *IndependentInstance) ApplyInterceptor(interceptor *support.Interceptor)

+ func (inst *IndependentInstance) ApplyPatch(patch *support.Patch)

+ func (inst *IndependentInstance) DoStep() bool

+ func (inst *IndependentInstance) GetChanges() *InstanceChangeTracker

+ func (inst *IndependentInstance) HandleGlobalError(containerInst *Instance, err error)

+ func (inst *IndependentInstance) MarshalJSON() ([]byte, error)

+ func (inst *IndependentInstance) ResetChanges()

+ func (inst *IndependentInstance) Restart(id string, manager *support.FlowManager) error

+ func (inst *IndependentInstance) Start(startAttrs map[string]*data.Attribute) bool

+ func (inst *IndependentInstance) StepID() int

+ func (inst *IndependentInstance) UnmarshalJSON(d []byte) error

type Instance

+ func (inst *Instance) FindOrCreateLinkData(link *definition.Link) (linkInst *LinkInst, created bool)

+ func (inst *Instance) FindOrCreateTaskData(task *definition.Task) (taskInst *TaskInst, created bool)

+ func (inst *Instance) GetResolver() data.Resolver

+ func (inst *Instance) IOMetadata() *data.IOMetadata

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

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

+ func (inst *Instance) SetResultHandler(handler action.ResultHandler)

+ func (inst *Instance) SetStatus(status model.FlowStatus)

+ func (inst *Instance) TaskInstances() []model.TaskInstance

+ func (inst *Instance) WorkingData() data.Scope

type InstanceChange

+ SubFlowChg *SubFlowChange

+ SubFlowID int

+ func (ic *InstanceChange) MarshalJSON() ([]byte, error)

type InstanceChangeTracker

+ func (ict *InstanceChangeTracker) SubFlowChange(parentFlowId int, chgType ChgType, subFlowId int, taskID string)

+ type LinkInst struct

+ func NewLinkInst(inst *Instance, link *definition.Link) *LinkInst

+ func (ld *LinkInst) Link() *definition.Link

+ func (ld *LinkInst) MarshalJSON() ([]byte, error)

+ func (ld *LinkInst) SetStatus(status model.LinkStatus)

+ func (ld *LinkInst) Status() model.LinkStatus

+ func (ld *LinkInst) UnmarshalJSON(d []byte) error

+ type LinkInstChange struct

+ ChgType ChgType

+ ID int

+ LinkInst *LinkInst

+ func (li *LinkInstChange) MarshalJSON() ([]byte, error)

type RecordStepReq

+ FlowURI string

+ type SubFlowChange struct

+ ChgType ChgType

+ SubFlowID int

+ TaskID string

+ type TaskInst struct

+ func NewTaskInst(inst *Instance, task *definition.Task) *TaskInst

+ func (ti *TaskInst) ActivityHost() activity.Host

+ func (ti *TaskInst) AddWorkingData(attr *data.Attribute)

+ func (ti *TaskInst) EvalActivity() (done bool, evalErr error)

+ func (ti *TaskInst) EvalLink(link *definition.Link) (result bool, err error)

+ func (ti *TaskInst) FlowDetails() activity.FlowDetails

+ func (ti *TaskInst) FlowReply(replyData map[string]*data.Attribute, err error)

+ func (ti *TaskInst) FlowReturn(returnData map[string]*data.Attribute, err error)

+ func (ti *TaskInst) GetFromLinkInstances() []model.LinkInstance

+ func (ti *TaskInst) GetInitValue(key string) (value interface{}, exists bool)

+ func (ti *TaskInst) GetInput(name string) interface{}

+ func (ti *TaskInst) GetOutput(name string) interface{}

+ func (ti *TaskInst) GetSetting(setting string) (value interface{}, exists bool)

+ func (ti *TaskInst) GetToLinkInstances() []model.LinkInstance

+ func (ti *TaskInst) GetWorkingData(key string) (*data.Attribute, bool)

+ func (ti *TaskInst) HasActivity() bool

+ func (ti *TaskInst) HasWorkingData() bool

+ func (ti *TaskInst) InputScope() data.Scope

+ func (ti *TaskInst) MarshalJSON() ([]byte, error)

+ func (ti *TaskInst) Name() string

+ func (ti *TaskInst) OutputScope() data.Scope

+ func (ti *TaskInst) PostEvalActivity() (done bool, evalErr error)

+ func (ti *TaskInst) Resolve(toResolve string) (value interface{}, err error)

+ func (ti *TaskInst) SetOutput(name string, value interface{})

+ func (ti *TaskInst) SetStatus(status model.TaskStatus)

+ func (ti *TaskInst) Status() model.TaskStatus

+ func (ti *TaskInst) Task() *definition.Task

+ func (ti *TaskInst) TaskName() string

+ func (ti *TaskInst) UnmarshalJSON(d []byte) error

+ func (ti *TaskInst) UpdateWorkingData(key string, value interface{}) error

+ type TaskInstChange struct

+ ChgType ChgType

+ ID string

+ TaskInst *TaskInst

+ func (ti *TaskInstChange) MarshalJSON() ([]byte, error)

type WorkItem

+ SubFlowID int

v0.5.2-rc4

Mar 17, 2018

v0.5.2-rc3

Mar 15, 2018

v0.5.2-rc2

Mar 15, 2018

v0.5.2-rc1

Mar 7, 2018

v0.5.1

Feb 1, 2018

Changes in this version

+ const OpRestart

+ const OpResume

+ const OpStart

+ func ApplyExecOptions(instance *Instance, execOptions *ExecOptions)

+ func DefaultConfig() *util.ServiceConfig

+ func NewFixedTaskScope(refAttrs map[string]*data.Attribute, task *definition.Task, isInput bool) data.Scope

+ func NewWorkingDataScope(parentScope data.Scope, workingData map[string]*data.Attribute) data.Scope

+ type ActionCtx struct

+ func (ac *ActionCtx) GetResolver() data.Resolver

+ func (ac *ActionCtx) ID() string

+ func (ac *ActionCtx) InstanceMetadata() *action.ConfigMetadata

+ func (ac *ActionCtx) Ref() string

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

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

+ func (ac *ActionCtx) WorkingData() data.Scope

+ type ActivityEvalError struct

+ func NewActivityEvalError(taskName string, errorType string, errorText string) *ActivityEvalError

+ func (e *ActivityEvalError) Error() string

+ func (e *ActivityEvalError) TaskName() string

+ func (e *ActivityEvalError) Type() string

+ type AttributeChange struct

+ Attribute *data.Attribute

+ ChgType ChgType

+ type ChgType int

+ const CtAdd

+ const CtDel

+ const CtUpd

+ type ExecOptions struct

+ Interceptor *support.Interceptor

+ Patch *support.Patch

+ type ExecType int

+ const EtEval

+ const EtPostEval

+ type FixedTaskScope struct

+ func (s *FixedTaskScope) GetAttr(attrName string) (attr *data.Attribute, exists bool)

+ func (s *FixedTaskScope) SetAttrValue(attrName string, value interface{}) error

+ type IDGenerator interface

+ NewFlowInstanceID func() string

+ type IDResponse struct

+ ID string

+ type Instance struct

+ Attrs map[string]*data.Attribute

+ ChangeTracker *InstanceChangeTracker

+ EhTaskEnv *TaskEnv

+ Flow *definition.Definition

+ FlowModel *model.FlowModel

+ FlowURI string

+ Interceptor *support.Interceptor

+ Patch *support.Patch

+ RootTaskEnv *TaskEnv

+ WorkItemQueue *util.SyncQueue

+ func New(instanceID string, flowURI string, flow *definition.Definition, ...) *Instance

+ func (pi *Instance) ActionContext() action.Context

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

+ func (pi *Instance) DoStep() bool

+ func (pi *Instance) FlowDefinition() *definition.Definition

+ func (pi *Instance) GetAttr(attrName string) (value *data.Attribute, exists bool)

+ func (pi *Instance) GetChanges() *InstanceChangeTracker

+ func (pi *Instance) GetReturnData() (map[string]*data.Attribute, error)

+ func (pi *Instance) HandleGlobalError()

+ func (pi *Instance) ID() string

+ func (pi *Instance) InitActionContext(config *action.Config, handler action.ResultHandler)

+ func (pi *Instance) MarshalJSON() ([]byte, error)

+ func (pi *Instance) Name() string

+ func (pi *Instance) ReplyHandler() activity.ReplyHandler

+ func (pi *Instance) ResetChanges()

+ func (pi *Instance) Restart(id string, provider provider.Provider)

+ func (pi *Instance) SetAttrValue(attrName string, value interface{}) error

+ func (pi *Instance) SetFlowProvider(provider provider.Provider)

+ func (pi *Instance) SetState(state int)

+ func (pi *Instance) Start(startAttrs []*data.Attribute) bool

+ func (pi *Instance) State() int

+ func (pi *Instance) Status() Status

+ func (pi *Instance) StepID() int

+ func (pi *Instance) UnmarshalJSON(d []byte) error

+ func (pi *Instance) UpdateAttrs(attrs []*data.Attribute)

+ type InstanceChange struct

+ AttrChanges []*AttributeChange

+ Changes int

+ State int

+ Status Status

+ type InstanceChangeTracker struct

+ func NewInstanceChangeTracker() *InstanceChangeTracker

+ func (ict *InstanceChangeTracker) AttrChange(chgType ChgType, attribute *data.Attribute)

+ func (ict *InstanceChangeTracker) MarshalJSON() ([]byte, error)

+ func (ict *InstanceChangeTracker) ResetChanges()

+ func (ict *InstanceChangeTracker) SetState(state int)

+ func (ict *InstanceChangeTracker) SetStatus(status Status)

+ type LinkData struct

+ func NewLinkData(taskEnv *TaskEnv, link *definition.Link) *LinkData

+ func (ld *LinkData) Link() *definition.Link

+ func (ld *LinkData) MarshalJSON() ([]byte, error)

+ func (ld *LinkData) SetState(state int)

+ func (ld *LinkData) State() int

+ func (ld *LinkData) UnmarshalJSON(d []byte) error

+ type LinkDataChange struct

+ ChgType ChgType

+ ID int

+ LinkData *LinkData

+ type RecordSnapshotReq struct

+ FlowID string

+ ID int

+ SnapshotData *Instance

+ State int

+ Status int

+ type RecordStepReq struct

+ FlowID string

+ ID int

+ State int

+ Status int

+ StepData *InstanceChangeTracker

+ type RemoteStateRecorder struct

+ func NewRemoteStateRecorder(config *util.ServiceConfig) *RemoteStateRecorder

+ func (sr *RemoteStateRecorder) Enabled() bool

+ func (sr *RemoteStateRecorder) Name() string

+ func (sr *RemoteStateRecorder) RecordSnapshot(instance *Instance)

+ func (sr *RemoteStateRecorder) RecordStep(instance *Instance)

+ func (sr *RemoteStateRecorder) Start() error

+ func (sr *RemoteStateRecorder) Stop() error

+ type RunOptions struct

+ ExecOptions *ExecOptions

+ FlowURI string

+ InitialState *Instance

+ Op int

+ ReturnID bool

+ type SimpleReplyHandler struct

+ func (rh *SimpleReplyHandler) Reply(code int, replyData interface{}, err error)

+ type StateRecorder interface

+ RecordSnapshot func(instance *Instance)

+ RecordStep func(instance *Instance)

+ type Status int

+ const StatusActive

+ const StatusCancelled

+ const StatusCompleted

+ const StatusFailed

+ const StatusNotStarted

+ type TaskData struct

+ func NewTaskData(taskEnv *TaskEnv, task *definition.Task) *TaskData

+ func (td *TaskData) ActionContext() action.Context

+ func (td *TaskData) AddWorkingData(attr *data.Attribute)

+ func (td *TaskData) ChildTaskInsts() (taskInsts []model.TaskInst, hasChildTasks bool)

+ func (td *TaskData) EnterChildren(taskEntries []*model.TaskEntry)

+ func (td *TaskData) EnterLeadingChildren(enterCode int)

+ func (td *TaskData) EvalActivity() (done bool, evalErr error)

+ func (td *TaskData) EvalLink(link *definition.Link) (result bool, err error)

+ func (td *TaskData) Failed(err error)

+ func (td *TaskData) FlowDetails() activity.FlowDetails

+ func (td *TaskData) FromInstLinks() []model.LinkInst

+ func (td *TaskData) GetInput(name string) interface{}

+ func (td *TaskData) GetOutput(name string) interface{}

+ func (td *TaskData) GetSetting(setting string) (value interface{}, exists bool)

+ func (td *TaskData) GetWorkingData(key string) (*data.Attribute, bool)

+ func (td *TaskData) HasActivity() bool

+ func (td *TaskData) HasAttrs() bool

+ func (td *TaskData) HasWorkingData() bool

+ func (td *TaskData) InputScope() data.Scope

+ func (td *TaskData) MarshalJSON() ([]byte, error)

+ func (td *TaskData) OutputScope() data.Scope

+ func (td *TaskData) SetOutput(name string, value interface{})

+ func (td *TaskData) SetState(state int)

+ func (td *TaskData) State() int

+ func (td *TaskData) Task() *definition.Task

+ func (td *TaskData) TaskName() string

+ func (td *TaskData) ToInstLinks() []model.LinkInst

+ func (td *TaskData) UnmarshalJSON(d []byte) error

+ func (td *TaskData) UpdateWorkingData(key string, value interface{}) error

+ type TaskDataChange struct

+ ChgType ChgType

+ ID string

+ TaskData *TaskData

+ type TaskEnv struct

+ ID int

+ Instance *Instance

+ LinkDatas map[int]*LinkData

+ ParentEnv *TaskEnv

+ Task *definition.Task

+ TaskDatas map[string]*TaskData

+ func (te *TaskEnv) FindOrCreateLinkData(link *definition.Link) (linkData *LinkData, created bool)

+ func (te *TaskEnv) FindOrCreateTaskData(task *definition.Task) (taskData *TaskData, created bool)

+ func (te *TaskEnv) MarshalJSON() ([]byte, error)

+ func (te *TaskEnv) NewTaskData(task *definition.Task) *TaskData

+ func (te *TaskEnv) UnmarshalJSON(data []byte) error

+ type WorkItem struct

+ EvalCode int

+ ExecType ExecType

+ ID int

+ TaskData *TaskData

+ TaskID string

+ func NewWorkItem(id int, taskData *TaskData, execType ExecType, evalCode int) *WorkItem

+ type WorkItemQueueChange struct

+ ChgType ChgType

+ ID int

+ WorkItem *WorkItem

+ type WorkingDataScope struct

+ func (s *WorkingDataScope) GetAttr(attrName string) (attr *data.Attribute, exists bool)

+ func (s *WorkingDataScope) SetAttrValue(attrName string, value interface{}) error

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