Versions in this module Expand all Collapse all v0 v0.5.8 Jan 19, 2019 Changes in this version + const OpRestart + const OpResume + const OpStart + func ApplyExecOptions(instance *IndependentInstance, execOptions *ExecOptions) + func DefaultConfig() *util.ServiceConfig + func GetFlowIOMetadata(flowURI string) (*data.IOMetadata, error) + 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 + func StartSubFlow(ctx activity.Context, flowURI string, inputs map[string]*data.Attribute) error + 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 + SubFlowID int + type ChgType int + const CtAdd + const CtDel + const CtUpd + type ExecOptions struct + Interceptor *support.Interceptor + Patch *support.Patch + 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 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 struct + func (inst *Instance) AddAttr(attrName string, attrType data.Type, value interface{}) *data.Attribute + 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) FlowDefinition() *definition.Definition + func (inst *Instance) FlowURI() string + func (inst *Instance) GetAttr(attrName string) (value *data.Attribute, exists bool) + func (inst *Instance) GetError() error + func (inst *Instance) GetResolver() data.Resolver + func (inst *Instance) GetReturnData() (map[string]*data.Attribute, error) + func (inst *Instance) ID() string + func (inst *Instance) IOMetadata() *data.IOMetadata + func (inst *Instance) MarshalJSON() ([]byte, error) + func (inst *Instance) Name() string + func (inst *Instance) Reply(replyData map[string]*data.Attribute, err error) + func (inst *Instance) ReplyHandler() activity.ReplyHandler + func (inst *Instance) Return(returnData map[string]*data.Attribute, err error) + func (inst *Instance) SetAttrValue(attrName string, value interface{}) error + func (inst *Instance) SetResultHandler(handler action.ResultHandler) + func (inst *Instance) SetStatus(status model.FlowStatus) + func (inst *Instance) Status() model.FlowStatus + func (inst *Instance) TaskInstances() []model.TaskInstance + func (inst *Instance) UnmarshalJSON(d []byte) error + func (inst *Instance) UpdateAttrs(attrs map[string]*data.Attribute) + func (inst *Instance) WorkingData() data.Scope + type InstanceChange struct + AttrChanges []*AttributeChange + State int + Status model.FlowStatus + SubFlowChg *SubFlowChange + SubFlowID int + func (ic *InstanceChange) MarshalJSON() ([]byte, error) + type InstanceChangeTracker struct + func NewInstanceChangeTracker() *InstanceChangeTracker + func (ict *InstanceChangeTracker) AttrChange(subFlowId int, chgType ChgType, attribute *data.Attribute) + func (ict *InstanceChangeTracker) MarshalJSON() ([]byte, error) + func (ict *InstanceChangeTracker) ResetChanges() + func (ict *InstanceChangeTracker) SetState(subFlowId int, state int) + func (ict *InstanceChangeTracker) SetStatus(subFlowId int, status model.FlowStatus) + 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 RecordSnapshotReq struct + FlowID string + ID int + SnapshotData *IndependentInstance + State int + Status int + type RecordStepReq struct + FlowID string + FlowURI 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 *IndependentInstance) + func (sr *RemoteStateRecorder) RecordStep(instance *IndependentInstance) + func (sr *RemoteStateRecorder) Start() error + func (sr *RemoteStateRecorder) Stop() error + type RunOptions struct + ExecOptions *ExecOptions + FlowURI string + InitialState *IndependentInstance + Op int + ReturnID bool + type SimpleReplyHandler struct + func (rh *SimpleReplyHandler) Reply(code int, replyData interface{}, err error) + type StateRecorder interface + RecordSnapshot func(instance *IndependentInstance) + RecordStep func(instance *IndependentInstance) + 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) GetSharedTempData() map[string]interface{} + 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 struct + ID int + SubFlowID int + TaskID string + func NewWorkItem(id int, taskInst *TaskInst) *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
Go to main page