interpreter

Dec 10, 2024

Changes in this version

+ func DeterministicKeys[K constraints.Ordered, V any](m map[K]V) []K

type ContinueAsNewer

+ func (c *ContinueAsNewer) GetSnapshot() service.ContinueAsNewDumpResponse

+ type InternalChannel struct

+ func NewInternalChannel() *InternalChannel

+ func RebuildInternalChannel(refill map[string][]*iwfidl.EncodedObject) *InternalChannel

+ func (i *InternalChannel) GetAllReceived() map[string][]*iwfidl.EncodedObject

+ func (i *InternalChannel) GetInfos() map[string]iwfidl.ChannelInfo

+ func (i *InternalChannel) HasData(channelName string) bool

+ func (i *InternalChannel) ProcessPublishing(publishes []iwfidl.InterStateChannelPublishing)

+ func (i *InternalChannel) Retrieve(channelName string) *iwfidl.EncodedObject

type SignalReceiver

+ func (sr *SignalReceiver) GetAllReceived() map[string][]*iwfidl.EncodedObject

+ func (sr *SignalReceiver) GetInfos() map[string]iwfidl.ChannelInfo

type WorkflowInfo

+ CurrentRunID string

Nov 22, 2024

Changes in this version

+ const StartingVersionNoIwfGlobalVersionSearchAttribute

+ const StartingVersionYieldOnConditionalComplete

+ func DrainReceivedButUnprocessedInternalChannelsFromStateApis(ctx UnifiedContext, provider WorkflowProvider, versioner *GlobalVersioner) error

type GlobalVersioner

+ func (p *GlobalVersioner) IsAfterVersionOfNoIwfGlobalVersionSearchAttribute() bool

+ func (p *GlobalVersioner) IsAfterVersionOfYieldOnConditionalComplete() bool

+ func (p *GlobalVersioner) IsUsingGlobalVersionSearchAttribute() bool

type SignalReceiver

+ func (sr *SignalReceiver) DrainAllReceivedButUnprocessedSignals(ctx UnifiedContext)

Nov 19, 2024

Changes in this version

+ const MaxOfAllVersions

+ const StartingVersionContinueAsNewOnNoStates

+ const StartingVersionExecutingStateIdMode

+ const StartingVersionOptimizedUpsertSearchAttribute

+ const StartingVersionRenamedStateApi

+ const StartingVersionTemporal26SDK

+ const StartingVersionUsingGlobalVersioning

type ActivityInfo

+ WorkflowExecution WorkflowExecution

Nov 1, 2024

Changes in this version

type GlobalVersioner

+ func (p *GlobalVersioner) IsAfterVersionOfExecutingStateIdMode() bool

Oct 18, 2024

Changes in this version

type GlobalVersioner

+ func (p *GlobalVersioner) IsAfterVersionOfTemporal26SDK() bool

type StateRequestQueue

+ func (srq *StateRequestQueue) GetAllStateResumeRequests() []service.StateExecutionResumeInfo

type WorkflowInfo

+ FirstRunID string

Sep 30, 2024

Changes in this version

+ type MockActivityProvider struct

+ func NewMockActivityProvider(ctrl *gomock.Controller) *MockActivityProvider

+ func (m *MockActivityProvider) EXPECT() *MockActivityProviderMockRecorder

+ func (m *MockActivityProvider) GetActivityInfo(ctx context.Context) ActivityInfo

+ func (m *MockActivityProvider) GetLogger(ctx context.Context) UnifiedLogger

+ func (m *MockActivityProvider) NewApplicationError(errType string, details interface{}) error

+ type MockActivityProviderMockRecorder struct

+ func (mr *MockActivityProviderMockRecorder) GetActivityInfo(ctx interface{}) *gomock.Call

+ func (mr *MockActivityProviderMockRecorder) GetLogger(ctx interface{}) *gomock.Call

+ func (mr *MockActivityProviderMockRecorder) NewApplicationError(errType, details interface{}) *gomock.Call

+ type MockFuture struct

+ func NewMockFuture(ctrl *gomock.Controller) *MockFuture

+ func (m *MockFuture) EXPECT() *MockFutureMockRecorder

+ func (m *MockFuture) Get(ctx UnifiedContext, valuePtr interface{}) error

+ func (m *MockFuture) IsReady() bool

+ type MockFutureMockRecorder struct

+ func (mr *MockFutureMockRecorder) Get(ctx, valuePtr interface{}) *gomock.Call

+ func (mr *MockFutureMockRecorder) IsReady() *gomock.Call

+ type MockReceiveChannel struct

+ func NewMockReceiveChannel(ctrl *gomock.Controller) *MockReceiveChannel

+ func (m *MockReceiveChannel) EXPECT() *MockReceiveChannelMockRecorder

+ func (m *MockReceiveChannel) ReceiveAsync(valuePtr interface{}) bool

+ func (m *MockReceiveChannel) ReceiveBlocking(ctx UnifiedContext, valuePtr interface{}) bool

+ type MockReceiveChannelMockRecorder struct

+ func (mr *MockReceiveChannelMockRecorder) ReceiveAsync(valuePtr interface{}) *gomock.Call

+ func (mr *MockReceiveChannelMockRecorder) ReceiveBlocking(ctx, valuePtr interface{}) *gomock.Call

+ type MockUnifiedContext struct

+ func NewMockUnifiedContext(ctrl *gomock.Controller) *MockUnifiedContext

+ func (m *MockUnifiedContext) EXPECT() *MockUnifiedContextMockRecorder

+ func (m *MockUnifiedContext) GetContext() interface{}

+ type MockUnifiedContextMockRecorder struct

+ func (mr *MockUnifiedContextMockRecorder) GetContext() *gomock.Call

+ type MockUnifiedLogger struct

+ func NewMockUnifiedLogger(ctrl *gomock.Controller) *MockUnifiedLogger

+ func (m *MockUnifiedLogger) Debug(msg string, keyvals ...interface{})

+ func (m *MockUnifiedLogger) EXPECT() *MockUnifiedLoggerMockRecorder

+ func (m *MockUnifiedLogger) Error(msg string, keyvals ...interface{})

+ func (m *MockUnifiedLogger) Info(msg string, keyvals ...interface{})

+ func (m *MockUnifiedLogger) Warn(msg string, keyvals ...interface{})

+ type MockUnifiedLoggerMockRecorder struct

+ func (mr *MockUnifiedLoggerMockRecorder) Debug(msg interface{}, keyvals ...interface{}) *gomock.Call

+ func (mr *MockUnifiedLoggerMockRecorder) Error(msg interface{}, keyvals ...interface{}) *gomock.Call

+ func (mr *MockUnifiedLoggerMockRecorder) Info(msg interface{}, keyvals ...interface{}) *gomock.Call

+ func (mr *MockUnifiedLoggerMockRecorder) Warn(msg interface{}, keyvals ...interface{}) *gomock.Call

+ type MockWorkflowProvider struct

+ func NewMockWorkflowProvider(ctrl *gomock.Controller) *MockWorkflowProvider

+ func (m *MockWorkflowProvider) Await(ctx UnifiedContext, condition func() bool) error

+ func (m *MockWorkflowProvider) EXPECT() *MockWorkflowProviderMockRecorder

+ func (m *MockWorkflowProvider) ExecuteActivity(valuePtr interface{}, optimizeByLocalActivity bool, ctx UnifiedContext, ...) error

+ func (m *MockWorkflowProvider) ExtendContextWithValue(parent UnifiedContext, key string, val interface{}) UnifiedContext

+ func (m *MockWorkflowProvider) GetBackendType() service.BackendType

+ func (m *MockWorkflowProvider) GetContextValue(ctx UnifiedContext, key string) interface{}

+ func (m *MockWorkflowProvider) GetLogger(ctx UnifiedContext) UnifiedLogger

+ func (m *MockWorkflowProvider) GetPendingThreadNames() map[string]int

+ func (m *MockWorkflowProvider) GetSearchAttributes(ctx UnifiedContext, ...) (map[string]iwfidl.SearchAttribute, error)

+ func (m *MockWorkflowProvider) GetSignalChannel(ctx UnifiedContext, signalName string) ReceiveChannel

+ func (m *MockWorkflowProvider) GetThreadCount() int

+ func (m *MockWorkflowProvider) GetUnhandledSignalNames(ctx UnifiedContext) []string

+ func (m *MockWorkflowProvider) GetVersion(ctx UnifiedContext, changeID string, minSupported, maxSupported int) int

+ func (m *MockWorkflowProvider) GetWorkflowInfo(ctx UnifiedContext) WorkflowInfo

+ func (m *MockWorkflowProvider) GoNamed(ctx UnifiedContext, name string, f func(UnifiedContext))

+ func (m *MockWorkflowProvider) IsApplicationError(err error) bool

+ func (m *MockWorkflowProvider) IsReplaying(ctx UnifiedContext) bool

+ func (m *MockWorkflowProvider) NewApplicationError(errType string, details interface{}) error

+ func (m *MockWorkflowProvider) NewInterpreterContinueAsNewError(ctx UnifiedContext, input service.InterpreterWorkflowInput) error

+ func (m *MockWorkflowProvider) NewTimer(ctx UnifiedContext, d time.Duration) Future

+ func (m *MockWorkflowProvider) Now(ctx UnifiedContext) time.Time

+ func (m *MockWorkflowProvider) SetQueryHandler(ctx UnifiedContext, queryType string, handler interface{}) error

+ func (m *MockWorkflowProvider) SetRpcUpdateHandler(ctx UnifiedContext, updateType string, validator UnifiedRpcValidator, ...) error

+ func (m *MockWorkflowProvider) Sleep(ctx UnifiedContext, d time.Duration) error

+ func (m *MockWorkflowProvider) UpsertMemo(ctx UnifiedContext, memo map[string]iwfidl.EncodedObject) error

+ func (m *MockWorkflowProvider) UpsertSearchAttributes(ctx UnifiedContext, attributes map[string]interface{}) error

+ func (m *MockWorkflowProvider) WithActivityOptions(ctx UnifiedContext, options ActivityOptions) UnifiedContext

+ type MockWorkflowProviderMockRecorder struct

+ func (mr *MockWorkflowProviderMockRecorder) Await(ctx, condition interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) ExecuteActivity(valuePtr, optimizeByLocalActivity, ctx, activity interface{}, ...) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) ExtendContextWithValue(parent, key, val interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetBackendType() *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetContextValue(ctx, key interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetLogger(ctx interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetPendingThreadNames() *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetSearchAttributes(ctx, requestedSearchAttributes interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetSignalChannel(ctx, signalName interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetThreadCount() *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetUnhandledSignalNames(ctx interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetVersion(ctx, changeID, minSupported, maxSupported interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GetWorkflowInfo(ctx interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) GoNamed(ctx, name, f interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) IsApplicationError(err interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) IsReplaying(ctx interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) NewApplicationError(errType, details interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) NewInterpreterContinueAsNewError(ctx, input interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) NewTimer(ctx, d interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) Now(ctx interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) SetQueryHandler(ctx, queryType, handler interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) SetRpcUpdateHandler(ctx, updateType, validator, handler interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) Sleep(ctx, d interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) UpsertMemo(ctx, memo interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) UpsertSearchAttributes(ctx, attributes interface{}) *gomock.Call

+ func (mr *MockWorkflowProviderMockRecorder) WithActivityOptions(ctx, options interface{}) *gomock.Call

May 31, 2024

Changes in this version

+ func FixTimerCommandFromActivityOutput(now time.Time, request iwfidl.CommandRequest) iwfidl.CommandRequest

type ActivityInfo

+ IsLocalActivity bool

type WorkflowConfiger

+ func (wc *WorkflowConfiger) ShouldOptimizeActivity() bool

+ func (wc *WorkflowConfiger) UpdateByAPI(config iwfidl.WorkflowConfig)

May 15, 2024

Changes in this version

type ContinueAsNewCounter

+ func (c *ContinueAsNewCounter) TriggerByAPI()

type GlobalVersioner

+ OmitVersionMarker bool

type WorkflowProvider

+ GetSearchAttributes func(ctx UnifiedContext, ...) (map[string]iwfidl.SearchAttribute, error)

Oct 23, 2023

Changes in this version

type WorkflowProvider

+ IsReplaying func(ctx UnifiedContext) bool

Sep 18, 2023

Changes in this version

+ func WaitForStateCompletionWorkflowImpl(ctx UnifiedContext, provider WorkflowProvider) (*service.WaitForStateCompletionWorkflowOutput, error)

type ContinueAsNewCounter

+ func (c *ContinueAsNewCounter) IncSyncUpdateReceived()

type ContinueAsNewer

+ func (c *ContinueAsNewer) DecreaseInflightOperation()

+ func (c *ContinueAsNewer) IncreaseInflightOperation()

type GlobalVersioner

+ func (p *GlobalVersioner) IsAfterVersionOfContinueAsNewOnNoStates() bool

+ type HandlerOutput struct

+ RpcOutput *iwfidl.WorkflowRpcResponse

+ StatusError *errors.ErrorAndStatus

+ type InvokeRpcActivityOutput struct

+ RpcOutput *iwfidl.WorkflowWorkerRpcResponse

+ StatusError *errors.ErrorAndStatus

+ func InvokeWorkerRpc(ctx context.Context, backendType service.BackendType, ...) (*InvokeRpcActivityOutput, error)

type PersistenceManager

+ func (am *PersistenceManager) CheckDataAndSearchAttributesKeysAreUnlocked(dataAttrKeysToCheck, searchAttrKeysToCheck []string) bool

type ReceiveChannel

+ ReceiveBlocking func(ctx UnifiedContext, valuePtr interface{}) (ok bool)

type StateRequest

+ func (sq StateRequest) GetStateMovement() iwfidl.StateMovement

type StateRequestQueue

+ func (srq *StateRequestQueue) AddSingleStateStartRequest(stateId string, input *iwfidl.EncodedObject, ...)

+ type UnifiedRpcHandler func(ctx UnifiedContext, input iwfidl.WorkflowRpcRequest) (*HandlerOutput, error)

+ type UnifiedRpcValidator func(ctx UnifiedContext, input iwfidl.WorkflowRpcRequest) error

type WorkflowInfo

+ WorkflowExecutionTimeout time.Duration

type WorkflowProvider

+ SetRpcUpdateHandler func(ctx UnifiedContext, updateType string, validator UnifiedRpcValidator, ...) error

+ type WorkflowUpdater struct

+ func NewWorkflowUpdater(ctx UnifiedContext, provider WorkflowProvider, ...) (*WorkflowUpdater, error)

Jun 5, 2023

Changes in this version

type WorkflowProvider

+ UpsertMemo func(ctx UnifiedContext, memo map[string]iwfidl.EncodedObject) error

May 8, 2023

Changes in this version

type PersistenceManager

+ func (am *PersistenceManager) UnlockPersistence(saPolicy *iwfidl.PersistenceLoadingPolicy, ...)

Apr 18, 2023

Changes in this version

+ func DumpWorkflowInternal(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowDumpResponse, error)

+ func GetSharedConfig() config.Config

+ func IsDeciderTriggerConditionMet(commandReq iwfidl.CommandRequest, ...) bool

+ func LastCaller() string

+ func LoadInternalsFromPreviousRun(ctx UnifiedContext, provider WorkflowProvider, previousRunId string, ...) (*service.ContinueAsNewDumpResponse, error)

+ func SetQueryHandlers(ctx UnifiedContext, provider WorkflowProvider, ...) error

+ func SetSharedConfig(config config.Config)

+ func StateApiExecute(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateDecideResponse, error)

+ func StateApiWaitUntil(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateStartResponse, error)

+ type ContinueAsNewCounter struct

+ func NewContinueAsCounter(configer *WorkflowConfiger, rootCtx UnifiedContext, provider WorkflowProvider) *ContinueAsNewCounter

+ func (c *ContinueAsNewCounter) IncExecutedStateExecution(skipStart bool)

+ func (c *ContinueAsNewCounter) IncSignalsReceived()

+ func (c *ContinueAsNewCounter) IsThresholdMet() bool

type ContinueAsNewer

+ StateExecutionToResumeMap map[string]service.StateExecutionResumeInfo

+ func (c *ContinueAsNewer) AddPotentialStateExecutionToResume(stateExecutionId string, state iwfidl.StateMovement, ...)

+ func (c *ContinueAsNewer) DrainThreads(ctx UnifiedContext) error

+ func (c *ContinueAsNewer) HasAnyStateExecutionToResume() bool

+ func (c *ContinueAsNewer) RemoveStateExecutionToResume(stateExecutionId string)

+ type GlobalVersioner struct

+ func NewGlobalVersioner(workflowProvider WorkflowProvider, ctx UnifiedContext) *GlobalVersioner

+ func (p *GlobalVersioner) IsAfterVersionOfOptimizedUpsertSearchAttribute() bool

+ func (p *GlobalVersioner) IsAfterVersionOfRenamedStateApi() bool

+ func (p *GlobalVersioner) IsAfterVersionOfUsingGlobalVersioning() bool

+ func (p *GlobalVersioner) UpsertGlobalVersionSearchAttribute() error

+ type OutputCollector struct

+ func NewOutputCollector(initOutputs []iwfidl.StateCompletionOutput) *OutputCollector

+ func (o *OutputCollector) Add(output iwfidl.StateCompletionOutput)

+ func (o *OutputCollector) GetAll() []iwfidl.StateCompletionOutput

type SignalReceiver

+ func (sr *SignalReceiver) DrainAllUnreceivedSignals(ctx UnifiedContext)

+ func (sr *SignalReceiver) DumpReceived(channelNames []string) map[string][]*iwfidl.EncodedObject

+ func (sr *SignalReceiver) IsFailWorkflowRequested() (bool, error)

type StateExecutionCounter

+ func RebuildStateExecutionCounter(ctx UnifiedContext, provider WorkflowProvider, ...) *StateExecutionCounter

+ func (e *StateExecutionCounter) ClearExecutingStateIdsSearchAttributeFinally()

+ func (e *StateExecutionCounter) GetTotalCurrentlyExecutingCount() int

+ func (e *StateExecutionCounter) MarkStateIdExecutingIfNotYet(stateReqs []StateRequest) error

+ type StateRequest struct

+ func NewStateResumeRequest(resumeRequest service.StateExecutionResumeInfo) StateRequest

+ func NewStateStartRequest(movement iwfidl.StateMovement) StateRequest

+ func (sq StateRequest) GetStateId() string

+ func (sq StateRequest) GetStateResumeRequest() service.StateExecutionResumeInfo

+ func (sq StateRequest) GetStateStartRequest() iwfidl.StateMovement

+ func (sq StateRequest) IsResumeRequest() bool

+ type StateRequestQueue struct

+ func NewStateRequestQueue() *StateRequestQueue

+ func NewStateRequestQueueWithResumeRequests(startReqs []iwfidl.StateMovement, ...) *StateRequestQueue

+ func (srq *StateRequestQueue) AddStateStartRequests(reqs []iwfidl.StateMovement)

+ func (srq *StateRequestQueue) GetAllStateStartRequests() []iwfidl.StateMovement

+ func (srq *StateRequestQueue) IsEmpty() bool

+ func (srq *StateRequestQueue) TakeAll() []StateRequest

type TimerProcessor

+ func (t *TimerProcessor) AddTimers(stateExeId string, commands []iwfidl.TimerCommand, ...)

+ func (t *TimerProcessor) Dump() []service.StaleSkipTimerSignal

+ func (t *TimerProcessor) RemovePendingTimersOfState(stateExeId string)

+ func (t *TimerProcessor) RetryStaleSkipTimer() bool

+ func (t *TimerProcessor) WaitForTimerFiredOrSkipped(ctx UnifiedContext, stateExeId string, timerIdx int, cancelWaiting *bool) service.InternalTimerStatus

+ type WorkflowConfiger struct

+ func NewWorkflowConfiger(config iwfidl.WorkflowConfig) *WorkflowConfiger

+ func (wc *WorkflowConfiger) Get() iwfidl.WorkflowConfig

+ func (wc *WorkflowConfiger) SetIfPresent(config iwfidl.WorkflowConfig)

type WorkflowProvider

+ GetPendingThreadNames func() map[string]int

+ GetThreadCount func() int

+ NewInterpreterContinueAsNewError func(ctx UnifiedContext, input service.InterpreterWorkflowInput) error

Feb 3, 2023

Changes in this version

+ func NewGlobalVersionProvider(workflowProvider WorkflowProvider) *globalVersioner

+ type ContinueAsNewer struct

+ func NewContinueAsNewer(interStateChannel *InterStateChannel, signalReceiver *SignalReceiver, ...) *ContinueAsNewer

+ func (c *ContinueAsNewer) AddPendingStateExecution(stateExecutionId string, completedTimerCommands map[int]bool, ...)

+ func (c *ContinueAsNewer) DeletePendingStateExecution(stateExecutionId string)

+ func (c *ContinueAsNewer) SetQueryHandlersForContinueAsNew(ctx UnifiedContext, provider WorkflowProvider) error

type InterStateChannel

+ func (i *InterStateChannel) ReadReceived(channelNames []string) map[string][]*iwfidl.EncodedObject

+ type SignalReceiver struct

+ func NewSignalReceiver(ctx UnifiedContext, provider WorkflowProvider) *SignalReceiver

+ func (sr *SignalReceiver) DrainedAllSignals(ctx UnifiedContext) error

+ func (sr *SignalReceiver) HasSignal(channelName string) bool

+ func (sr *SignalReceiver) ReadReceived(channelNames []string) map[string][]*iwfidl.EncodedObject

+ func (sr *SignalReceiver) Retrieve(channelName string) *iwfidl.EncodedObject

+ type StateExecutionCounter struct

+ func NewStateExecutionCounter(ctx UnifiedContext, provider WorkflowProvider) *StateExecutionCounter

+ func RebuildStateExecutionManager(ctx UnifiedContext, provider WorkflowProvider, ...) *StateExecutionCounter

+ func (e *StateExecutionCounter) CreateNextExecutionId(stateId string) string

+ func (e *StateExecutionCounter) Dump() service.StateExecutionCounterInfo

+ func (e *StateExecutionCounter) GetTotalPendingStateExecutions() int

+ func (e *StateExecutionCounter) MarkStateExecutionCompleted(state iwfidl.StateMovement) error

+ func (e *StateExecutionCounter) MarkStateExecutionsPending(states []iwfidl.StateMovement) error

type WorkflowProvider

+ GetUnhandledSignalNames func(ctx UnifiedContext) []string

+ IsApplicationError func(err error) bool

Jan 19, 2023

Changes in this version

+ type ActivityInfo struct

+ Attempt int32

+ ScheduledTime time.Time

type ActivityProvider

+ GetActivityInfo func(ctx context.Context) ActivityInfo

Jan 9, 2023

Changes in this version

+ func WaitForDeciderTriggerType(provider WorkflowProvider, ctx UnifiedContext, ...)

type InterStateChannel

+ func RebuildInterStateChannel(refill map[string][]*iwfidl.EncodedObject) *InterStateChannel

+ func (i *InterStateChannel) ReadData(channelNames []string) map[string][]*iwfidl.EncodedObject

type PersistenceManager

+ func RebuildPersistenceManager(provider WorkflowProvider, dolist []iwfidl.KeyValue, ...) *PersistenceManager

+ type TimerProcessor struct

+ func NewTimerProcessor(ctx UnifiedContext, provider WorkflowProvider) *TimerProcessor

+ func (t *TimerProcessor) FinishProcessing(stateExeId string)

+ func (t *TimerProcessor) GetCurrentTimerInfos() map[string][]*service.TimerInfo

+ func (t *TimerProcessor) SkipTimer(stateExeId, timerId string, timerIdx int)

+ func (t *TimerProcessor) StartProcessing(stateExeId string, commands []iwfidl.TimerCommand)

+ func (t *TimerProcessor) WaitForTimerCompleted(ctx UnifiedContext, stateExeId string, timerIdx int, cancelWaiting *bool) bool

+ type UnifiedLogger interface

+ Debug func(msg string, keyvals ...interface{})

+ Error func(msg string, keyvals ...interface{})

+ Info func(msg string, keyvals ...interface{})

+ Warn func(msg string, keyvals ...interface{})

type WorkflowProvider

+ GetLogger func(ctx UnifiedContext) UnifiedLogger

Dec 29, 2022

Changes in this version

+ func InterpreterImpl(ctx UnifiedContext, provider WorkflowProvider, ...) (*service.InterpreterWorkflowOutput, error)

+ func RegisterActivityProvider(backendType service.BackendType, provider ActivityProvider)

+ func StateDecide(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateDecideResponse, error)

+ func StateStart(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateStartResponse, error)

+ type ActivityLogger interface

+ Debug func(msg string, keyvals ...interface{})

+ Error func(msg string, keyvals ...interface{})

+ Info func(msg string, keyvals ...interface{})

+ Warn func(msg string, keyvals ...interface{})

+ type ActivityOptions struct

+ RetryPolicy *iwfidl.RetryPolicy

+ StartToCloseTimeout time.Duration

+ type ActivityProvider interface

+ GetLogger func(ctx context.Context) ActivityLogger

+ NewApplicationError func(message, errType string, details ...interface{}) error

+ type Future interface

+ Get func(ctx UnifiedContext, valuePtr interface{}) error

+ IsReady func() bool

+ type InterStateChannel struct

+ func NewInterStateChannel() *InterStateChannel

+ func (i *InterStateChannel) HasData(channelName string) bool

+ func (i *InterStateChannel) ProcessPublishing(publishes []iwfidl.InterStateChannelPublishing)

+ func (i *InterStateChannel) Retrieve(channelName string) *iwfidl.EncodedObject

+ type PersistenceManager struct

+ func NewPersistenceManager(searchAttributeUpserter func(attributes map[string]interface{}) error) *PersistenceManager

+ func (am *PersistenceManager) GetAllDataObjects() []iwfidl.KeyValue

+ func (am *PersistenceManager) GetAllSearchAttributes() []iwfidl.SearchAttribute

+ func (am *PersistenceManager) GetDataObjectsByKey(request service.GetDataObjectsQueryRequest) service.GetDataObjectsQueryResponse

+ func (am *PersistenceManager) LoadDataObjects(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.KeyValue

+ func (am *PersistenceManager) LoadSearchAttributes(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.SearchAttribute

+ func (am *PersistenceManager) ProcessUpsertDataObject(attributes []iwfidl.KeyValue) error

+ func (am *PersistenceManager) ProcessUpsertSearchAttribute(attributes []iwfidl.SearchAttribute) error

+ type ReceiveChannel interface

+ Receive func(ctx UnifiedContext, valuePtr interface{}) (more bool)

+ ReceiveAsync func(valuePtr interface{}) (ok bool)

+ type StateExecutionIdManager struct

+ func NewStateExecutionIdManager() *StateExecutionIdManager

+ func (sm *StateExecutionIdManager) IncAndGetNextExecutionId(stateId string) string

+ type UnifiedContext interface

+ GetContext func() interface{}

+ func NewUnifiedContext(ctx interface{}) UnifiedContext

+ type WorkflowExecution struct

+ ID string

+ RunID string

+ type WorkflowInfo struct

+ WorkflowExecution WorkflowExecution

+ WorkflowStartTime time.Time

+ type WorkflowProvider interface

+ Await func(ctx UnifiedContext, condition func() bool) error

+ ExecuteActivity func(ctx UnifiedContext, activity interface{}, args ...interface{}) (future Future)

+ ExtendContextWithValue func(parent UnifiedContext, key string, val interface{}) UnifiedContext

+ GetBackendType func() service.BackendType

+ GetContextValue func(ctx UnifiedContext, key string) interface{}

+ GetSignalChannel func(ctx UnifiedContext, signalName string) (receiveChannel ReceiveChannel)

+ GetVersion func(ctx UnifiedContext, changeID string, minSupported, maxSupported int) int

+ GetWorkflowInfo func(ctx UnifiedContext) WorkflowInfo

+ GoNamed func(ctx UnifiedContext, name string, f func(ctx UnifiedContext))

+ NewApplicationError func(message, errType string, details ...interface{}) error

+ NewTimer func(ctx UnifiedContext, d time.Duration) Future

+ Now func(ctx UnifiedContext) time.Time

+ SetQueryHandler func(ctx UnifiedContext, queryType string, handler interface{}) error

+ Sleep func(ctx UnifiedContext, d time.Duration) (err error)

+ UpsertSearchAttributes func(ctx UnifiedContext, attributes map[string]interface{}) error

+ WithActivityOptions func(ctx UnifiedContext, options ActivityOptions) UnifiedContext