Versions in this module Expand all Collapse all v1 v1.0.3 Jul 23, 2019 v1.0.2 Jul 23, 2019 v1.0.1 Jul 16, 2019 v1.0.0 Jun 25, 2019 Changes in this version + const OpRestart + const OpResume + const OpStart + func ApplyExecOptions(instance *IndependentInstance, execOptions *ExecOptions) + func DefaultConfig() *support.ServiceConfig + func GetFlowIOMetadata(flowURI string) (*metadata.IOMetadata, error) + func NewErrorObj(taskId string, msg string) map[string]interface + func StartSubFlow(ctx activity.Context, flowURI string, inputs map[string]interface{}) 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 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, error) + func (inst *IndependentInstance) ApplyInterceptor(interceptor *flowsupport.Interceptor) + func (inst *IndependentInstance) ApplyPatch(patch *flowsupport.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 *flowsupport.FlowManager) error + func (inst *IndependentInstance) Start(startAttrs map[string]interface{}) bool + func (inst *IndependentInstance) StepID() int + func (inst *IndependentInstance) UnmarshalJSON(d []byte) error + type Instance struct + 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) GetError() error + func (inst *Instance) GetReturnData() (map[string]interface{}, error) + func (inst *Instance) GetValue(name string) (value interface{}, exists bool) + func (inst *Instance) ID() string + func (inst *Instance) IOMetadata() *metadata.IOMetadata + func (inst *Instance) Logger() log.Logger + func (inst *Instance) MarshalJSON() ([]byte, error) + func (inst *Instance) Name() string + func (inst *Instance) Reply(replyData map[string]interface{}, err error) + func (inst *Instance) Return(returnData map[string]interface{}, err error) + func (inst *Instance) Scope() data.Scope + func (inst *Instance) SetResultHandler(handler action.ResultHandler) + func (inst *Instance) SetStatus(status model.FlowStatus) + func (inst *Instance) SetValue(name string, value interface{}) error + 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]interface{}) + 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 LegacyCtx struct + func (l *LegacyCtx) ActivityHost() activity.Host + func (l *LegacyCtx) GetInput(name string) interface{} + func (l *LegacyCtx) GetInputObject(input data.StructValue) error + func (l *LegacyCtx) GetInputSchema(name string) schema.Schema + func (l *LegacyCtx) GetOutput(name string) interface{} + func (l *LegacyCtx) GetOutputSchema(name string) schema.Schema + func (l *LegacyCtx) GetSetting(name string) (interface{}, bool) + func (l *LegacyCtx) GetSharedTempData() map[string]interface{} + func (l *LegacyCtx) Logger() log.Logger + func (l *LegacyCtx) Name() string + func (l *LegacyCtx) SetOutput(name string, value interface{}) error + func (l *LegacyCtx) SetOutputObject(output data.StructValue) error + 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 *support.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 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) EvalActivity() (done bool, evalErr error) + func (ti *TaskInst) EvalLink(link *definition.Link) (result bool, err error) + func (ti *TaskInst) FlowLogger() log.Logger + func (ti *TaskInst) GetFromLinkInstances() []model.LinkInstance + func (ti *TaskInst) GetInput(name string) interface{} + func (ti *TaskInst) GetInputObject(input data.StructValue) error + func (ti *TaskInst) GetInputSchema(name string) schema.Schema + func (ti *TaskInst) GetOutputSchema(name string) schema.Schema + func (ti *TaskInst) GetSetting(name string) (value interface{}, exists bool) + func (ti *TaskInst) GetSharedTempData() map[string]interface{} + func (ti *TaskInst) GetToLinkInstances() []model.LinkInstance + func (ti *TaskInst) GetWorkingData(key string) (interface{}, bool) + func (ti *TaskInst) HasActivity() bool + func (ti *TaskInst) Logger() log.Logger + func (ti *TaskInst) MarshalJSON() ([]byte, error) + func (ti *TaskInst) Name() string + func (ti *TaskInst) PostEvalActivity() (done bool, evalErr error) + func (ti *TaskInst) SetOutput(name string, value interface{}) error + func (ti *TaskInst) SetOutputObject(output data.StructValue) error + func (ti *TaskInst) SetStatus(status model.TaskStatus) + func (ti *TaskInst) SetWorkingData(key string, value interface{}) + func (ti *TaskInst) Status() model.TaskStatus + func (ti *TaskInst) Task() *definition.Task + func (ti *TaskInst) UnmarshalJSON(d []byte) 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 NewWorkingDataScope(parentScope data.Scope) *WorkingDataScope + func (s *WorkingDataScope) GetValue(name string) (value interface{}, exists bool) + func (s *WorkingDataScope) GetWorkingValue(name string) (value interface{}, exists bool) + func (s *WorkingDataScope) SetValue(name string, value interface{}) error + func (s *WorkingDataScope) SetWorkingValue(name string, value interface{})
Go to main page