interpreter

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 1, 2024 License: MIT Imports: 27 Imported by: 0

Documentation

Overview

Package interpreter is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DumpWorkflowInternal added in v1.5.0 

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

func FixTimerCommandFromActivityOutput added in v1.9.1 

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

FixTimerCommandFromActivityOutput converts the durationSeconds to firingUnixTimestampSeconds doing it right after the activity output so that we don't need to worry about the time drift after continueAsNew

func InterpreterImpl 

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

func IsDeciderTriggerConditionMet added in v1.5.0 

func IsDeciderTriggerConditionMet(
	commandReq iwfidl.CommandRequest,
	completedTimerCmds map[int]service.InternalTimerStatus,
	completedSignalCmds map[int]*iwfidl.EncodedObject,
	completedInterStateChannelCmds map[int]*iwfidl.EncodedObject,
) bool

func LastCaller added in v1.5.0 

func LastCaller() string

func LoadInternalsFromPreviousRun added in v1.5.0 

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

func RegisterActivityProvider 

func RegisterActivityProvider(backendType service.BackendType, provider ActivityProvider)

func SetQueryHandlers added in v1.5.0 

func SetQueryHandlers(
	ctx UnifiedContext, provider WorkflowProvider, persistenceManager *PersistenceManager,
	continueAsNewer *ContinueAsNewer,
	workflowConfiger *WorkflowConfiger, basicInfo service.BasicInfo,
) error

func StateApiExecute added in v1.5.0 

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

func StateApiWaitUntil added in v1.5.0 

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

func StateDecide 

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

StateDecide is deprecated. Will be removed in next release

func StateStart 

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

StateStart is Deprecated, will be removed in next release

func WaitForStateCompletionWorkflowImpl added in v1.8.0 

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

Types

type ActivityInfo added in v1.2.2 

type ActivityInfo struct {
	ScheduledTime   time.Time // Time of activity scheduled by a workflow
	Attempt         int32     // Attempt starts from 1, and increased by 1 for every retry if retry policy is specified.
	IsLocalActivity bool      // Whether the activity is at local activity
}

type ActivityOptions 

type ActivityOptions struct {
	StartToCloseTimeout time.Duration
	RetryPolicy         *iwfidl.RetryPolicy
}

type ActivityProvider 

type ActivityProvider interface {
	GetLogger(ctx context.Context) UnifiedLogger
	NewApplicationError(errType string, details interface{}) error
	GetActivityInfo(ctx context.Context) ActivityInfo
}

type ContinueAsNewCounter added in v1.5.0 

type ContinueAsNewCounter struct {
	// contains filtered or unexported fields
}

func NewContinueAsCounter added in v1.5.0 

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

func (*ContinueAsNewCounter) IncExecutedStateExecution added in v1.5.0 

func (c *ContinueAsNewCounter) IncExecutedStateExecution(skipStart bool)

func (*ContinueAsNewCounter) IncSignalsReceived added in v1.5.0 

func (c *ContinueAsNewCounter) IncSignalsReceived()

func (*ContinueAsNewCounter) IncSyncUpdateReceived added in v1.8.0 

func (c *ContinueAsNewCounter) IncSyncUpdateReceived()

func (*ContinueAsNewCounter) IsThresholdMet added in v1.5.0 

func (c *ContinueAsNewCounter) IsThresholdMet() bool

func (*ContinueAsNewCounter) TriggerByAPI added in v1.9.0 

func (c *ContinueAsNewCounter) TriggerByAPI()

type ContinueAsNewer added in v1.3.0 

type ContinueAsNewer struct {
	StateExecutionToResumeMap map[string]service.StateExecutionResumeInfo // stateExeId to StateExecutionResumeInfo
	// contains filtered or unexported fields
}

func NewContinueAsNewer added in v1.3.0 

func NewContinueAsNewer(
	provider WorkflowProvider,
	interStateChannel *InterStateChannel, signalReceiver *SignalReceiver, stateExecutionCounter *StateExecutionCounter,
	persistenceManager *PersistenceManager, stateRequestQueue *StateRequestQueue, collector *OutputCollector,
	timerProcessor *TimerProcessor,
) *ContinueAsNewer

func (*ContinueAsNewer) AddPotentialStateExecutionToResume added in v1.5.0 

func (c *ContinueAsNewer) AddPotentialStateExecutionToResume(
	stateExecutionId string, state iwfidl.StateMovement, stateExecLocals []iwfidl.KeyValue,
	commandRequest iwfidl.CommandRequest,
	completedTimerCommands map[int]service.InternalTimerStatus,
	completedSignalCommands, completedInterStateChannelCommands map[int]*iwfidl.EncodedObject,
)

func (*ContinueAsNewer) DecreaseInflightOperation added in v1.8.0 

func (c *ContinueAsNewer) DecreaseInflightOperation()

func (*ContinueAsNewer) DrainThreads added in v1.5.0 

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

func (*ContinueAsNewer) HasAnyStateExecutionToResume added in v1.5.0 

func (c *ContinueAsNewer) HasAnyStateExecutionToResume() bool

func (*ContinueAsNewer) IncreaseInflightOperation added in v1.8.0 

func (c *ContinueAsNewer) IncreaseInflightOperation()

func (*ContinueAsNewer) RemoveStateExecutionToResume added in v1.5.0 

func (c *ContinueAsNewer) RemoveStateExecutionToResume(stateExecutionId string)

func (*ContinueAsNewer) SetQueryHandlersForContinueAsNew added in v1.3.0 

func (c *ContinueAsNewer) SetQueryHandlersForContinueAsNew(ctx UnifiedContext) error

type Future 

type Future interface {
	Get(ctx UnifiedContext, valuePtr interface{}) error
	IsReady() bool
}

type GlobalVersioner added in v1.5.0 

type GlobalVersioner struct {
	OmitVersionMarker bool // indicate the version marker and upsertSearchAttribute is already set at the start of the workflow
	// contains filtered or unexported fields
}

GlobalVersioner see https://stackoverflow.com/questions/73941723/what-is-a-good-way-pattern-to-use-temporal-cadence-versioning-api

func NewGlobalVersioner added in v1.5.0 

func NewGlobalVersioner(
	workflowProvider WorkflowProvider, omitVersionMarker bool, ctx UnifiedContext,
) (*GlobalVersioner, error)

func (*GlobalVersioner) IsAfterVersionOfContinueAsNewOnNoStates added in v1.8.0 

func (p *GlobalVersioner) IsAfterVersionOfContinueAsNewOnNoStates() bool

func (*GlobalVersioner) IsAfterVersionOfExecutingStateIdMode added in v1.11.1 

func (p *GlobalVersioner) IsAfterVersionOfExecutingStateIdMode() bool

func (*GlobalVersioner) IsAfterVersionOfOptimizedUpsertSearchAttribute added in v1.5.0 

func (p *GlobalVersioner) IsAfterVersionOfOptimizedUpsertSearchAttribute() bool

func (*GlobalVersioner) IsAfterVersionOfRenamedStateApi added in v1.5.0 

func (p *GlobalVersioner) IsAfterVersionOfRenamedStateApi() bool

func (*GlobalVersioner) IsAfterVersionOfTemporal26SDK added in v1.11.0 

func (p *GlobalVersioner) IsAfterVersionOfTemporal26SDK() bool

func (*GlobalVersioner) IsAfterVersionOfUsingGlobalVersioning added in v1.5.0 

func (p *GlobalVersioner) IsAfterVersionOfUsingGlobalVersioning() bool

func (*GlobalVersioner) UpsertGlobalVersionSearchAttribute added in v1.5.0 

func (p *GlobalVersioner) UpsertGlobalVersionSearchAttribute() error

type HandlerOutput added in v1.8.0 

type HandlerOutput struct {
	RpcOutput   *iwfidl.WorkflowRpcResponse
	StatusError *errors.ErrorAndStatus
}

type InterStateChannel 

type InterStateChannel struct {
	// contains filtered or unexported fields
}

func NewInterStateChannel 

func NewInterStateChannel() *InterStateChannel

func RebuildInterStateChannel added in v1.2.0 

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

func (*InterStateChannel) HasData 

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

func (*InterStateChannel) ProcessPublishing 

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

func (*InterStateChannel) ReadReceived added in v1.3.0 

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

func (*InterStateChannel) Retrieve 

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

type InvokeRpcActivityOutput added in v1.8.0 

type InvokeRpcActivityOutput struct {
	RpcOutput   *iwfidl.WorkflowWorkerRpcResponse
	StatusError *errors.ErrorAndStatus
}

func InvokeWorkerRpc added in v1.8.0 

func InvokeWorkerRpc(
	ctx context.Context, backendType service.BackendType, rpcPrep *service.PrepareRpcQueryResponse,
	req iwfidl.WorkflowRpcRequest,
) (*InvokeRpcActivityOutput, error)

type MockActivityProvider added in v1.10.0 

type MockActivityProvider struct {
	// contains filtered or unexported fields
}

MockActivityProvider is a mock of ActivityProvider interface.

func NewMockActivityProvider added in v1.10.0 

func NewMockActivityProvider(ctrl *gomock.Controller) *MockActivityProvider

NewMockActivityProvider creates a new mock instance.

func (*MockActivityProvider) EXPECT added in v1.10.0 

func (m *MockActivityProvider) EXPECT() *MockActivityProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockActivityProvider) GetActivityInfo added in v1.10.0 

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

GetActivityInfo mocks base method.

func (*MockActivityProvider) GetLogger added in v1.10.0 

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

GetLogger mocks base method.

func (*MockActivityProvider) NewApplicationError added in v1.10.0 

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

NewApplicationError mocks base method.

type MockActivityProviderMockRecorder added in v1.10.0 

type MockActivityProviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockActivityProviderMockRecorder is the mock recorder for MockActivityProvider.

func (*MockActivityProviderMockRecorder) GetActivityInfo added in v1.10.0 

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

GetActivityInfo indicates an expected call of GetActivityInfo.

func (*MockActivityProviderMockRecorder) GetLogger added in v1.10.0 

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

GetLogger indicates an expected call of GetLogger.

func (*MockActivityProviderMockRecorder) NewApplicationError added in v1.10.0 

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

NewApplicationError indicates an expected call of NewApplicationError.

type MockFuture added in v1.10.0 

type MockFuture struct {
	// contains filtered or unexported fields
}

MockFuture is a mock of Future interface.

func NewMockFuture added in v1.10.0 

func NewMockFuture(ctrl *gomock.Controller) *MockFuture

NewMockFuture creates a new mock instance.

func (*MockFuture) EXPECT added in v1.10.0 

func (m *MockFuture) EXPECT() *MockFutureMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFuture) Get added in v1.10.0 

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

Get mocks base method.

func (*MockFuture) IsReady added in v1.10.0 

func (m *MockFuture) IsReady() bool

IsReady mocks base method.

type MockFutureMockRecorder added in v1.10.0 

type MockFutureMockRecorder struct {
	// contains filtered or unexported fields
}

MockFutureMockRecorder is the mock recorder for MockFuture.

func (*MockFutureMockRecorder) Get added in v1.10.0 

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

Get indicates an expected call of Get.

func (*MockFutureMockRecorder) IsReady added in v1.10.0 

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

IsReady indicates an expected call of IsReady.

type MockReceiveChannel added in v1.10.0 

type MockReceiveChannel struct {
	// contains filtered or unexported fields
}

MockReceiveChannel is a mock of ReceiveChannel interface.

func NewMockReceiveChannel added in v1.10.0 

func NewMockReceiveChannel(ctrl *gomock.Controller) *MockReceiveChannel

NewMockReceiveChannel creates a new mock instance.

func (*MockReceiveChannel) EXPECT added in v1.10.0 

func (m *MockReceiveChannel) EXPECT() *MockReceiveChannelMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReceiveChannel) ReceiveAsync added in v1.10.0 

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

ReceiveAsync mocks base method.

func (*MockReceiveChannel) ReceiveBlocking added in v1.10.0 

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

ReceiveBlocking mocks base method.

type MockReceiveChannelMockRecorder added in v1.10.0 

type MockReceiveChannelMockRecorder struct {
	// contains filtered or unexported fields
}

MockReceiveChannelMockRecorder is the mock recorder for MockReceiveChannel.

func (*MockReceiveChannelMockRecorder) ReceiveAsync added in v1.10.0 

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

ReceiveAsync indicates an expected call of ReceiveAsync.

func (*MockReceiveChannelMockRecorder) ReceiveBlocking added in v1.10.0 

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

ReceiveBlocking indicates an expected call of ReceiveBlocking.

type MockUnifiedContext added in v1.10.0 

type MockUnifiedContext struct {
	// contains filtered or unexported fields
}

MockUnifiedContext is a mock of UnifiedContext interface.

func NewMockUnifiedContext added in v1.10.0 

func NewMockUnifiedContext(ctrl *gomock.Controller) *MockUnifiedContext

NewMockUnifiedContext creates a new mock instance.

func (*MockUnifiedContext) EXPECT added in v1.10.0 

func (m *MockUnifiedContext) EXPECT() *MockUnifiedContextMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUnifiedContext) GetContext added in v1.10.0 

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

GetContext mocks base method.

type MockUnifiedContextMockRecorder added in v1.10.0 

type MockUnifiedContextMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnifiedContextMockRecorder is the mock recorder for MockUnifiedContext.

func (*MockUnifiedContextMockRecorder) GetContext added in v1.10.0 

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

GetContext indicates an expected call of GetContext.

type MockUnifiedLogger added in v1.10.0 

type MockUnifiedLogger struct {
	// contains filtered or unexported fields
}

MockUnifiedLogger is a mock of UnifiedLogger interface.

func NewMockUnifiedLogger added in v1.10.0 

func NewMockUnifiedLogger(ctrl *gomock.Controller) *MockUnifiedLogger

NewMockUnifiedLogger creates a new mock instance.

func (*MockUnifiedLogger) Debug added in v1.10.0 

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

Debug mocks base method.

func (*MockUnifiedLogger) EXPECT added in v1.10.0 

func (m *MockUnifiedLogger) EXPECT() *MockUnifiedLoggerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUnifiedLogger) Error added in v1.10.0 

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

Error mocks base method.

func (*MockUnifiedLogger) Info added in v1.10.0 

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

Info mocks base method.

func (*MockUnifiedLogger) Warn added in v1.10.0 

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

Warn mocks base method.

type MockUnifiedLoggerMockRecorder added in v1.10.0 

type MockUnifiedLoggerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnifiedLoggerMockRecorder is the mock recorder for MockUnifiedLogger.

func (*MockUnifiedLoggerMockRecorder) Debug added in v1.10.0 

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

Debug indicates an expected call of Debug.

func (*MockUnifiedLoggerMockRecorder) Error added in v1.10.0 

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

Error indicates an expected call of Error.

func (*MockUnifiedLoggerMockRecorder) Info added in v1.10.0 

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

Info indicates an expected call of Info.

func (*MockUnifiedLoggerMockRecorder) Warn added in v1.10.0 

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

Warn indicates an expected call of Warn.

type MockWorkflowProvider added in v1.10.0 

type MockWorkflowProvider struct {
	// contains filtered or unexported fields
}

MockWorkflowProvider is a mock of WorkflowProvider interface.

func NewMockWorkflowProvider added in v1.10.0 

func NewMockWorkflowProvider(ctrl *gomock.Controller) *MockWorkflowProvider

NewMockWorkflowProvider creates a new mock instance.

func (*MockWorkflowProvider) Await added in v1.10.0 

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

Await mocks base method.

func (*MockWorkflowProvider) EXPECT added in v1.10.0 

func (m *MockWorkflowProvider) EXPECT() *MockWorkflowProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockWorkflowProvider) ExecuteActivity added in v1.10.0 

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

ExecuteActivity mocks base method.

func (*MockWorkflowProvider) ExtendContextWithValue added in v1.10.0 

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

ExtendContextWithValue mocks base method.

func (*MockWorkflowProvider) GetBackendType added in v1.10.0 

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

GetBackendType mocks base method.

func (*MockWorkflowProvider) GetContextValue added in v1.10.0 

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

GetContextValue mocks base method.

func (*MockWorkflowProvider) GetLogger added in v1.10.0 

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

GetLogger mocks base method.

func (*MockWorkflowProvider) GetPendingThreadNames added in v1.10.0 

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

GetPendingThreadNames mocks base method.

func (*MockWorkflowProvider) GetSearchAttributes added in v1.10.0 

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

GetSearchAttributes mocks base method.

func (*MockWorkflowProvider) GetSignalChannel added in v1.10.0 

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

GetSignalChannel mocks base method.

func (*MockWorkflowProvider) GetThreadCount added in v1.10.0 

func (m *MockWorkflowProvider) GetThreadCount() int

GetThreadCount mocks base method.

func (*MockWorkflowProvider) GetUnhandledSignalNames added in v1.10.0 

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

GetUnhandledSignalNames mocks base method.

func (*MockWorkflowProvider) GetVersion added in v1.10.0 

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

GetVersion mocks base method.

func (*MockWorkflowProvider) GetWorkflowInfo added in v1.10.0 

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

GetWorkflowInfo mocks base method.

func (*MockWorkflowProvider) GoNamed added in v1.10.0 

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

GoNamed mocks base method.

func (*MockWorkflowProvider) IsApplicationError added in v1.10.0 

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

IsApplicationError mocks base method.

func (*MockWorkflowProvider) IsReplaying added in v1.10.0 

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

IsReplaying mocks base method.

func (*MockWorkflowProvider) NewApplicationError added in v1.10.0 

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

NewApplicationError mocks base method.

func (*MockWorkflowProvider) NewInterpreterContinueAsNewError added in v1.10.0 

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

NewInterpreterContinueAsNewError mocks base method.

func (*MockWorkflowProvider) NewTimer added in v1.10.0 

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

NewTimer mocks base method.

func (*MockWorkflowProvider) Now added in v1.10.0 

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

Now mocks base method.

func (*MockWorkflowProvider) SetQueryHandler added in v1.10.0 

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

SetQueryHandler mocks base method.

func (*MockWorkflowProvider) SetRpcUpdateHandler added in v1.10.0 

func (m *MockWorkflowProvider) SetRpcUpdateHandler(ctx UnifiedContext, updateType string, validator UnifiedRpcValidator, handler UnifiedRpcHandler) error

SetRpcUpdateHandler mocks base method.

func (*MockWorkflowProvider) Sleep added in v1.10.0 

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

Sleep mocks base method.

func (*MockWorkflowProvider) UpsertMemo added in v1.10.0 

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

UpsertMemo mocks base method.

func (*MockWorkflowProvider) UpsertSearchAttributes added in v1.10.0 

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

UpsertSearchAttributes mocks base method.

func (*MockWorkflowProvider) WithActivityOptions added in v1.10.0 

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

WithActivityOptions mocks base method.

type MockWorkflowProviderMockRecorder added in v1.10.0 

type MockWorkflowProviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockWorkflowProviderMockRecorder is the mock recorder for MockWorkflowProvider.

func (*MockWorkflowProviderMockRecorder) Await added in v1.10.0 

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

Await indicates an expected call of Await.

func (*MockWorkflowProviderMockRecorder) ExecuteActivity added in v1.10.0 

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

ExecuteActivity indicates an expected call of ExecuteActivity.

func (*MockWorkflowProviderMockRecorder) ExtendContextWithValue added in v1.10.0 

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

ExtendContextWithValue indicates an expected call of ExtendContextWithValue.

func (*MockWorkflowProviderMockRecorder) GetBackendType added in v1.10.0 

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

GetBackendType indicates an expected call of GetBackendType.

func (*MockWorkflowProviderMockRecorder) GetContextValue added in v1.10.0 

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

GetContextValue indicates an expected call of GetContextValue.

func (*MockWorkflowProviderMockRecorder) GetLogger added in v1.10.0 

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

GetLogger indicates an expected call of GetLogger.

func (*MockWorkflowProviderMockRecorder) GetPendingThreadNames added in v1.10.0 

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

GetPendingThreadNames indicates an expected call of GetPendingThreadNames.

func (*MockWorkflowProviderMockRecorder) GetSearchAttributes added in v1.10.0 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockWorkflowProviderMockRecorder) GetSignalChannel added in v1.10.0 

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

GetSignalChannel indicates an expected call of GetSignalChannel.

func (*MockWorkflowProviderMockRecorder) GetThreadCount added in v1.10.0 

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

GetThreadCount indicates an expected call of GetThreadCount.

func (*MockWorkflowProviderMockRecorder) GetUnhandledSignalNames added in v1.10.0 

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

GetUnhandledSignalNames indicates an expected call of GetUnhandledSignalNames.

func (*MockWorkflowProviderMockRecorder) GetVersion added in v1.10.0 

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

GetVersion indicates an expected call of GetVersion.

func (*MockWorkflowProviderMockRecorder) GetWorkflowInfo added in v1.10.0 

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

GetWorkflowInfo indicates an expected call of GetWorkflowInfo.

func (*MockWorkflowProviderMockRecorder) GoNamed added in v1.10.0 

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

GoNamed indicates an expected call of GoNamed.

func (*MockWorkflowProviderMockRecorder) IsApplicationError added in v1.10.0 

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

IsApplicationError indicates an expected call of IsApplicationError.

func (*MockWorkflowProviderMockRecorder) IsReplaying added in v1.10.0 

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

IsReplaying indicates an expected call of IsReplaying.

func (*MockWorkflowProviderMockRecorder) NewApplicationError added in v1.10.0 

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

NewApplicationError indicates an expected call of NewApplicationError.

func (*MockWorkflowProviderMockRecorder) NewInterpreterContinueAsNewError added in v1.10.0 

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

NewInterpreterContinueAsNewError indicates an expected call of NewInterpreterContinueAsNewError.

func (*MockWorkflowProviderMockRecorder) NewTimer added in v1.10.0 

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

NewTimer indicates an expected call of NewTimer.

func (*MockWorkflowProviderMockRecorder) Now added in v1.10.0 

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

Now indicates an expected call of Now.

func (*MockWorkflowProviderMockRecorder) SetQueryHandler added in v1.10.0 

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

SetQueryHandler indicates an expected call of SetQueryHandler.

func (*MockWorkflowProviderMockRecorder) SetRpcUpdateHandler added in v1.10.0 

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

SetRpcUpdateHandler indicates an expected call of SetRpcUpdateHandler.

func (*MockWorkflowProviderMockRecorder) Sleep added in v1.10.0 

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

Sleep indicates an expected call of Sleep.

func (*MockWorkflowProviderMockRecorder) UpsertMemo added in v1.10.0 

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

UpsertMemo indicates an expected call of UpsertMemo.

func (*MockWorkflowProviderMockRecorder) UpsertSearchAttributes added in v1.10.0 

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

UpsertSearchAttributes indicates an expected call of UpsertSearchAttributes.

func (*MockWorkflowProviderMockRecorder) WithActivityOptions added in v1.10.0 

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

WithActivityOptions indicates an expected call of WithActivityOptions.

type OutputCollector added in v1.5.0 

type OutputCollector struct {
	// contains filtered or unexported fields
}

func NewOutputCollector added in v1.5.0 

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

func (*OutputCollector) Add added in v1.5.0 

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

func (*OutputCollector) GetAll added in v1.5.0 

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

type PersistenceManager 

type PersistenceManager struct {
	// contains filtered or unexported fields
}

func NewPersistenceManager 

func NewPersistenceManager(
	provider WorkflowProvider, initDataAttributes []iwfidl.KeyValue, initSearchAttributes []iwfidl.SearchAttribute, useMemo bool,
) *PersistenceManager

func RebuildPersistenceManager added in v1.2.0 

func RebuildPersistenceManager(
	provider WorkflowProvider,
	dolist []iwfidl.KeyValue, salist []iwfidl.SearchAttribute,
	useMemo bool,
) *PersistenceManager

func (*PersistenceManager) CheckDataAndSearchAttributesKeysAreUnlocked added in v1.8.0 

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

func (*PersistenceManager) GetAllDataObjects 

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

func (*PersistenceManager) GetAllSearchAttributes 

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

func (*PersistenceManager) GetDataObjectsByKey 

func (am *PersistenceManager) GetDataObjectsByKey(request service.GetDataAttributesQueryRequest) service.GetDataAttributesQueryResponse

func (*PersistenceManager) LoadDataObjects 

func (am *PersistenceManager) LoadDataObjects(
	ctx UnifiedContext, loadingPolicy *iwfidl.PersistenceLoadingPolicy,
) []iwfidl.KeyValue

func (*PersistenceManager) LoadSearchAttributes 

func (am *PersistenceManager) LoadSearchAttributes(
	ctx UnifiedContext, loadingPolicy *iwfidl.PersistenceLoadingPolicy,
) []iwfidl.SearchAttribute

func (*PersistenceManager) ProcessUpsertDataObject 

func (am *PersistenceManager) ProcessUpsertDataObject(ctx UnifiedContext, attributes []iwfidl.KeyValue) error

func (*PersistenceManager) ProcessUpsertSearchAttribute 

func (am *PersistenceManager) ProcessUpsertSearchAttribute(
	ctx UnifiedContext, attributes []iwfidl.SearchAttribute,
) error

func (*PersistenceManager) UnlockPersistence added in v1.5.1 

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

type ReceiveChannel 

type ReceiveChannel interface {
	ReceiveAsync(valuePtr interface{}) (ok bool)
	ReceiveBlocking(ctx UnifiedContext, valuePtr interface{}) (ok bool)
}

type SignalReceiver added in v1.3.0 

type SignalReceiver struct {
	// contains filtered or unexported fields
}

func NewSignalReceiver added in v1.3.0 

func NewSignalReceiver(
	ctx UnifiedContext, provider WorkflowProvider, interStateChannel *InterStateChannel,
	stateRequestQueue *StateRequestQueue,
	persistenceManager *PersistenceManager, tp *TimerProcessor, continueAsNewCounter *ContinueAsNewCounter,
	workflowConfiger *WorkflowConfiger,
	initReceivedSignals map[string][]*iwfidl.EncodedObject,
) *SignalReceiver

func (*SignalReceiver) DrainAllUnreceivedSignals added in v1.5.0 

func (sr *SignalReceiver) DrainAllUnreceivedSignals(ctx UnifiedContext)

DrainAllUnreceivedSignals will process all the signals There are two cases this is needed: 1. ContinueAsNew: retrieve signals that after signal handler threads are stopped, so that the signals can be carried over to next run by continueAsNew. This includes both regular user signals and system signals 2. Conditional close/complete workflow on signal/internal channel: retrieve all signal/internal channel messages before checking the signal/internal channels

func (*SignalReceiver) DumpReceived added in v1.5.0 

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

func (*SignalReceiver) HasSignal added in v1.3.0 

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

func (*SignalReceiver) IsFailWorkflowRequested added in v1.5.0 

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

func (*SignalReceiver) Retrieve added in v1.3.0 

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

type StateExecutionCounter added in v1.3.0 

type StateExecutionCounter struct {
	// contains filtered or unexported fields
}

func NewStateExecutionCounter added in v1.3.0 

func NewStateExecutionCounter(
	ctx UnifiedContext, provider WorkflowProvider, globalVersioner *GlobalVersioner,
	configer *WorkflowConfiger, continueAsNewCounter *ContinueAsNewCounter,
) *StateExecutionCounter

func RebuildStateExecutionCounter added in v1.5.0 

func RebuildStateExecutionCounter(
	ctx UnifiedContext, provider WorkflowProvider, globalVersioner *GlobalVersioner,
	stateIdStartedCounts map[string]int, stateIdCurrentlyExecutingCounts map[string]int,
	totalCurrentlyExecutingCount int,
	configer *WorkflowConfiger, continueAsNewCounter *ContinueAsNewCounter,
) *StateExecutionCounter

func (*StateExecutionCounter) ClearExecutingStateIdsSearchAttributeFinally added in v1.5.0 

func (e *StateExecutionCounter) ClearExecutingStateIdsSearchAttributeFinally()

ClearExecutingStateIdsSearchAttributeFinally should only be called at the end of workflow

func (*StateExecutionCounter) CreateNextExecutionId added in v1.3.0 

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

func (*StateExecutionCounter) Dump added in v1.3.0 

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

func (*StateExecutionCounter) GetTotalCurrentlyExecutingCount added in v1.5.0 

func (e *StateExecutionCounter) GetTotalCurrentlyExecutingCount() int

func (*StateExecutionCounter) MarkStateExecutionCompleted added in v1.3.0 

func (e *StateExecutionCounter) MarkStateExecutionCompleted(currentState iwfidl.StateMovement, nextStates []iwfidl.StateMovement) error

func (*StateExecutionCounter) MarkStateIdExecutingIfNotYet added in v1.5.0 

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

type StateRequest added in v1.5.0 

type StateRequest struct {
	// contains filtered or unexported fields
}

func NewStateResumeRequest added in v1.5.0 

func NewStateResumeRequest(resumeRequest service.StateExecutionResumeInfo) StateRequest

func NewStateStartRequest added in v1.5.0 

func NewStateStartRequest(movement iwfidl.StateMovement) StateRequest

func (StateRequest) GetStateId added in v1.5.0 

func (sq StateRequest) GetStateId() string

func (StateRequest) GetStateMovement added in v1.8.0 

func (sq StateRequest) GetStateMovement() iwfidl.StateMovement

func (StateRequest) GetStateResumeRequest added in v1.5.0 

func (sq StateRequest) GetStateResumeRequest() service.StateExecutionResumeInfo

func (StateRequest) GetStateStartRequest added in v1.5.0 

func (sq StateRequest) GetStateStartRequest() iwfidl.StateMovement

func (StateRequest) IsResumeRequest added in v1.5.0 

func (sq StateRequest) IsResumeRequest() bool

type StateRequestQueue added in v1.5.0 

type StateRequestQueue struct {
	// contains filtered or unexported fields
}

func NewStateRequestQueue added in v1.5.0 

func NewStateRequestQueue() *StateRequestQueue

func NewStateRequestQueueWithResumeRequests added in v1.5.0 

func NewStateRequestQueueWithResumeRequests(startReqs []iwfidl.StateMovement, resumeReqs map[string]service.StateExecutionResumeInfo) *StateRequestQueue

func (*StateRequestQueue) AddSingleStateStartRequest added in v1.8.0 

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

func (*StateRequestQueue) AddStateStartRequests added in v1.5.0 

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

func (*StateRequestQueue) GetAllStateResumeRequests added in v1.11.0 

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

func (*StateRequestQueue) GetAllStateStartRequests added in v1.5.0 

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

func (*StateRequestQueue) IsEmpty added in v1.5.0 

func (srq *StateRequestQueue) IsEmpty() bool

func (*StateRequestQueue) TakeAll added in v1.5.0 

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

type TimerProcessor added in v1.2.0 

type TimerProcessor struct {
	// contains filtered or unexported fields
}

func NewTimerProcessor added in v1.2.0 

func NewTimerProcessor(
	ctx UnifiedContext, provider WorkflowProvider, staleSkipTimerSignals []service.StaleSkipTimerSignal,
) *TimerProcessor

func (*TimerProcessor) AddTimers added in v1.5.0 

func (t *TimerProcessor) AddTimers(
	stateExeId string, commands []iwfidl.TimerCommand, completedTimerCmds map[int]service.InternalTimerStatus,
)

func (*TimerProcessor) Dump added in v1.5.0 

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

func (*TimerProcessor) GetCurrentTimerInfos added in v1.2.0 

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

func (*TimerProcessor) RemovePendingTimersOfState added in v1.5.0 

func (t *TimerProcessor) RemovePendingTimersOfState(stateExeId string)

RemovePendingTimersOfState is for when a state is completed, remove all its pending timers

func (*TimerProcessor) RetryStaleSkipTimer added in v1.5.0 

func (t *TimerProcessor) RetryStaleSkipTimer() bool

func (*TimerProcessor) SkipTimer added in v1.2.0 

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

SkipTimer will attempt to skip a timer, return false if no valid timer found

func (*TimerProcessor) WaitForTimerFiredOrSkipped added in v1.5.0 

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

WaitForTimerFiredOrSkipped waits for timer completed(fired or skipped), return true when the timer is fired or skipped return false if the waitingCommands is canceled by cancelWaiting bool pointer(when the trigger type is completed, or continueAsNew)

type UnifiedContext 

type UnifiedContext interface {
	GetContext() interface{}
}

func NewUnifiedContext 

func NewUnifiedContext(ctx interface{}) UnifiedContext

type UnifiedLogger added in v1.2.0 

type UnifiedLogger interface {
	Debug(msg string, keyvals ...interface{})
	Info(msg string, keyvals ...interface{})
	Warn(msg string, keyvals ...interface{})
	Error(msg string, keyvals ...interface{})
}

type UnifiedRpcHandler added in v1.8.0 

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

type UnifiedRpcValidator added in v1.8.0 

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

type WorkflowConfiger added in v1.5.0 

type WorkflowConfiger struct {
	// contains filtered or unexported fields
}

func NewWorkflowConfiger added in v1.5.0 

func NewWorkflowConfiger(config iwfidl.WorkflowConfig) *WorkflowConfiger

func (*WorkflowConfiger) Get added in v1.5.0 

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

func (*WorkflowConfiger) ShouldOptimizeActivity added in v1.9.1 

func (wc *WorkflowConfiger) ShouldOptimizeActivity() bool

func (*WorkflowConfiger) UpdateByAPI added in v1.9.1 

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

type WorkflowExecution 

type WorkflowExecution struct {
	ID    string
	RunID string
}

WorkflowExecution details.

type WorkflowInfo 

type WorkflowInfo struct {
	WorkflowExecution        WorkflowExecution
	WorkflowStartTime        time.Time
	WorkflowExecutionTimeout time.Duration
	FirstRunID               string
}

WorkflowInfo information about currently executing workflow

type WorkflowProvider 

type WorkflowProvider interface {
	NewApplicationError(errType string, details interface{}) error
	IsApplicationError(err error) bool
	GetWorkflowInfo(ctx UnifiedContext) WorkflowInfo
	GetSearchAttributes(
		ctx UnifiedContext, requestedSearchAttributes []iwfidl.SearchAttributeKeyAndType,
	) (map[string]iwfidl.SearchAttribute, error)
	UpsertSearchAttributes(ctx UnifiedContext, attributes map[string]interface{}) error
	UpsertMemo(ctx UnifiedContext, memo map[string]iwfidl.EncodedObject) error
	SetQueryHandler(ctx UnifiedContext, queryType string, handler interface{}) error
	SetRpcUpdateHandler(
		ctx UnifiedContext, updateType string, validator UnifiedRpcValidator, handler UnifiedRpcHandler,
	) error
	ExtendContextWithValue(parent UnifiedContext, key string, val interface{}) UnifiedContext
	GoNamed(ctx UnifiedContext, name string, f func(ctx UnifiedContext))
	GetThreadCount() int
	GetPendingThreadNames() map[string]int
	Await(ctx UnifiedContext, condition func() bool) error
	WithActivityOptions(ctx UnifiedContext, options ActivityOptions) UnifiedContext
	ExecuteActivity(
		valuePtr interface{}, optimizeByLocalActivity bool, ctx UnifiedContext, activity interface{},
		args ...interface{},
	) (err error)
	Now(ctx UnifiedContext) time.Time
	IsReplaying(ctx UnifiedContext) bool
	Sleep(ctx UnifiedContext, d time.Duration) (err error)
	NewTimer(ctx UnifiedContext, d time.Duration) Future
	GetSignalChannel(ctx UnifiedContext, signalName string) (receiveChannel ReceiveChannel)
	GetContextValue(ctx UnifiedContext, key string) interface{}
	GetVersion(ctx UnifiedContext, changeID string, minSupported, maxSupported int) int
	GetUnhandledSignalNames(ctx UnifiedContext) []string
	GetBackendType() service.BackendType
	GetLogger(ctx UnifiedContext) UnifiedLogger
	NewInterpreterContinueAsNewError(ctx UnifiedContext, input service.InterpreterWorkflowInput) error
}

type WorkflowUpdater added in v1.8.0 

type WorkflowUpdater struct {
	// contains filtered or unexported fields
}

func NewWorkflowUpdater added in v1.8.0 

func NewWorkflowUpdater(
	ctx UnifiedContext, provider WorkflowProvider, persistenceManager *PersistenceManager,
	stateRequestQueue *StateRequestQueue,
	continueAsNewer *ContinueAsNewer, continueAsNewCounter *ContinueAsNewCounter, configer *WorkflowConfiger,
	interStateChannel *InterStateChannel, basicInfo service.BasicInfo, globalVersioner *GlobalVersioner,
) (*WorkflowUpdater, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.