instance

package

Go to main page

Versions in this module

v0

v0.2.7

Feb 12, 2024

v0.2.5

Feb 12, 2024

v0.2.4

Feb 12, 2024

v0.2.3

Feb 12, 2024

v0.2.2

Feb 12, 2024

v0.2.1

Feb 12, 2024

v0.0.7

Feb 7, 2024

Changes in this version

type IndependentInstance

+ func (inst *IndependentInstance) GetInterceptor() *flowsupport.Interceptor

type RunOptions

+ OriginalInstanceId string

v0.0.6

Feb 7, 2024

Changes in this version

+ func NewStateInstanceRecorder(recorder state.Recorder, mod state.RecordingMode, rerunstate bool) *stateInstanceRecorder

type ChangeTracker

+ FlowDone func(flow *IndependentInstance)

+ SubflowDone func(subflow *Instance)

type IndependentInstance

+ func (inst *IndependentInstance) ExecutionTime() time.Duration

+ func (inst *IndependentInstance) GetFlowState(inputs map[string]interface{}) *state.FlowState

+ func (inst *IndependentInstance) RecordState(strtTime time.Time) error

+ func (inst *IndependentInstance) SetInstanceRecorder(stateRecorder *stateInstanceRecorder)

+ func (inst *IndependentInstance) UpdateStartTime()

type Instance

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

type NoopChangeTracker

+ func (nct *NoopChangeTracker) FlowDone(flow *IndependentInstance)

+ func (nct *NoopChangeTracker) SubflowDone(subflow *Instance)

type RunOptions

+ InitStepId int

+ PreservedInstanceId string

+ Rerun bool

type SimpleChangeTracker

+ func (sct *SimpleChangeTracker) FlowDone(flow *IndependentInstance)

+ func (sct *SimpleChangeTracker) SubflowDone(subflow *Instance)

type TaskInst

+ func (ti *TaskInst) SetOutputs(outputs map[string]interface{}) error

+ func (ti *TaskInst) UpdateTaskToTracker()

v0.0.5

Feb 7, 2024

v0.0.4

Feb 7, 2024

Changes in this version

type ChangeTracker

+ FlowCreated func(flow *IndependentInstance)

type Instance

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

type NoopChangeTracker

+ func (nct *NoopChangeTracker) FlowCreated(flow *IndependentInstance)

type SimpleChangeTracker

+ func (sct *SimpleChangeTracker) FlowCreated(flow *IndependentInstance)

v0.0.3

Feb 7, 2024

v0.0.2

Feb 7, 2024

Changes in this version

+ func EnableChangeTracking(enable bool)

+ type ChangeTracker interface

+ AttrChange func(subflowId int, name string, value interface{})

+ ExtractStep func(reset bool) *state.Step

+ LinkAdded func(linkInst *LinkInst)

+ LinkRemoved func(subflowId int, linkId int)

+ LinkUpdated func(linkInst *LinkInst)

+ SetStatus func(subflowId int, status model.FlowStatus)

+ SubflowCreated func(subflow *Instance)

+ TaskAdded func(taskInst *TaskInst)

+ TaskRemoved func(subflowId int, taskId string)

+ TaskUpdated func(taskInst *TaskInst)

+ WorkItemAdded func(wi *WorkItem)

+ WorkItemRemoved func(wi *WorkItem)

type IndependentInstance

+ func (inst *IndependentInstance) CurrentStep(reset bool) *state.Step

+ func (inst *IndependentInstance) SetTracingContext(tracingCtx trace.TracingContext)

+ func (inst *IndependentInstance) Snapshot() *state.Snapshot

type Instance

+ func (inst *Instance) SpanConfig() trace.Config

+ func (inst *Instance) TracingContext() trace.TracingContext

type LegacyCtx

+ func (l *LegacyCtx) GetSetting(name string) (interface{}, bool)

+ func (l *LegacyCtx) GetTracingContext() trace.TracingContext

+ type NoopChangeTracker struct

+ func (nct *NoopChangeTracker) AttrChange(subflowId int, name string, value interface{})

+ func (nct *NoopChangeTracker) ExtractStep(reset bool) *state.Step

+ func (nct *NoopChangeTracker) LinkAdded(linkInst *LinkInst)

+ func (nct *NoopChangeTracker) LinkRemoved(subflowId int, linkId int)

+ func (nct *NoopChangeTracker) LinkUpdated(linkInst *LinkInst)

+ func (nct *NoopChangeTracker) SetStatus(subflowId int, status model.FlowStatus)

+ func (nct *NoopChangeTracker) SubflowCreated(subflow *Instance)

+ func (nct *NoopChangeTracker) TaskAdded(taskInst *TaskInst)

+ func (nct *NoopChangeTracker) TaskRemoved(subflowId int, taskId string)

+ func (nct *NoopChangeTracker) TaskUpdated(taskInst *TaskInst)

+ func (nct *NoopChangeTracker) WorkItemAdded(wi *WorkItem)

+ func (nct *NoopChangeTracker) WorkItemRemoved(wi *WorkItem)

+ type SimpleChangeTracker struct

+ func (sct *SimpleChangeTracker) AttrChange(subflowId int, name string, value interface{})

+ func (sct *SimpleChangeTracker) ExtractStep(reset bool) *state.Step

+ func (sct *SimpleChangeTracker) LinkAdded(linkInst *LinkInst)

+ func (sct *SimpleChangeTracker) LinkRemoved(subflowId int, linkId int)

+ func (sct *SimpleChangeTracker) LinkUpdated(linkInst *LinkInst)

+ func (sct *SimpleChangeTracker) SetStatus(subflowId int, status model.FlowStatus)

+ func (sct *SimpleChangeTracker) SubflowCreated(subflow *Instance)

+ func (sct *SimpleChangeTracker) TaskAdded(taskInst *TaskInst)

+ func (sct *SimpleChangeTracker) TaskRemoved(subflowId int, taskId string)

+ func (sct *SimpleChangeTracker) TaskUpdated(taskInst *TaskInst)

+ func (sct *SimpleChangeTracker) WorkItemAdded(wi *WorkItem)

+ func (sct *SimpleChangeTracker) WorkItemRemoved(wi *WorkItem)

+ type SimpleChangeTrackerFactory struct

+ func (sf *SimpleChangeTrackerFactory) NewChangeTracker(flowId string) ChangeTracker

type TaskInst

+ func (ti *TaskInst) Accumulated() bool

+ func (ti *TaskInst) GetTracingContext() trace.TracingContext

+ func (ti *TaskInst) GetWorkingDataScope() *WorkingDataScope

+ func (ti *TaskInst) InstanceId() string

+ func (ti *TaskInst) SpanConfig() trace.Config

v0.0.1

Feb 7, 2024

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) 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{})

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