interfaces

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2025 License: MIT Imports: 7 Imported by: 0

README

To refresh the generated code:

mockgen -source ./service/interpreter/interfaces/interfaces.go -destination ./service/interpreter/interfaces/interfaces_mock.go -package interfaces

Documentation

Overview

Package interfaces is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterActivityProvider 

func RegisterActivityProvider(backendType service.BackendType, provider ActivityProvider)

Types

type ActivityInfo 

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
	WorkflowExecution WorkflowExecution
}

type ActivityOptions 

type ActivityOptions struct {
	StartToCloseTimeout time.Duration
	HeartbeatTimeout    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
	RecordHeartbeat(ctx context.Context, details ...interface{})
}

func GetActivityProviderByType 

func GetActivityProviderByType(backendType service.BackendType) ActivityProvider

type Future 

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

type HandlerOutput 

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

type InvokeRpcActivityOutput 

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

type MockActivityProvider 

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

MockActivityProvider is a mock of ActivityProvider interface.

func NewMockActivityProvider 

func NewMockActivityProvider(ctrl *gomock.Controller) *MockActivityProvider

NewMockActivityProvider creates a new mock instance.

func (*MockActivityProvider) EXPECT 

func (m *MockActivityProvider) EXPECT() *MockActivityProviderMockRecorder

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

func (*MockActivityProvider) GetActivityInfo 

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

GetActivityInfo mocks base method.

func (*MockActivityProvider) GetLogger 

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

GetLogger mocks base method.

func (*MockActivityProvider) NewApplicationError 

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

NewApplicationError mocks base method.

func (*MockActivityProvider) RecordHeartbeat added in v1.19.0 

func (m *MockActivityProvider) RecordHeartbeat(ctx context.Context, details ...interface{})

RecordHeartbeat mocks base method.

type MockActivityProviderMockRecorder 

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

MockActivityProviderMockRecorder is the mock recorder for MockActivityProvider.

func (*MockActivityProviderMockRecorder) GetActivityInfo 

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

GetActivityInfo indicates an expected call of GetActivityInfo.

func (*MockActivityProviderMockRecorder) GetLogger 

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

GetLogger indicates an expected call of GetLogger.

func (*MockActivityProviderMockRecorder) NewApplicationError 

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

NewApplicationError indicates an expected call of NewApplicationError.

func (*MockActivityProviderMockRecorder) RecordHeartbeat added in v1.19.0 

func (mr *MockActivityProviderMockRecorder) RecordHeartbeat(ctx interface{}, details ...interface{}) *gomock.Call

RecordHeartbeat indicates an expected call of RecordHeartbeat.

type MockFuture 

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

MockFuture is a mock of Future interface.

func NewMockFuture 

func NewMockFuture(ctrl *gomock.Controller) *MockFuture

NewMockFuture creates a new mock instance.

func (*MockFuture) EXPECT 

func (m *MockFuture) EXPECT() *MockFutureMockRecorder

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

func (*MockFuture) Get 

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

Get mocks base method.

func (*MockFuture) IsReady 

func (m *MockFuture) IsReady() bool

IsReady mocks base method.

type MockFutureMockRecorder 

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

MockFutureMockRecorder is the mock recorder for MockFuture.

func (*MockFutureMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockFutureMockRecorder) IsReady 

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

IsReady indicates an expected call of IsReady.

type MockReceiveChannel 

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

MockReceiveChannel is a mock of ReceiveChannel interface.

func NewMockReceiveChannel 

func NewMockReceiveChannel(ctrl *gomock.Controller) *MockReceiveChannel

NewMockReceiveChannel creates a new mock instance.

func (*MockReceiveChannel) EXPECT 

func (m *MockReceiveChannel) EXPECT() *MockReceiveChannelMockRecorder

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

func (*MockReceiveChannel) ReceiveAsync 

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

ReceiveAsync mocks base method.

func (*MockReceiveChannel) ReceiveBlocking 

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

ReceiveBlocking mocks base method.

type MockReceiveChannelMockRecorder 

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

MockReceiveChannelMockRecorder is the mock recorder for MockReceiveChannel.

func (*MockReceiveChannelMockRecorder) ReceiveAsync 

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

ReceiveAsync indicates an expected call of ReceiveAsync.

func (*MockReceiveChannelMockRecorder) ReceiveBlocking 

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

ReceiveBlocking indicates an expected call of ReceiveBlocking.

type MockTimerProcessor added in v1.19.0 

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

MockTimerProcessor is a mock of TimerProcessor interface.

func NewMockTimerProcessor added in v1.19.0 

func NewMockTimerProcessor(ctrl *gomock.Controller) *MockTimerProcessor

NewMockTimerProcessor creates a new mock instance.

func (*MockTimerProcessor) AddTimers added in v1.19.0 

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

AddTimers mocks base method.

func (*MockTimerProcessor) Dump added in v1.19.0 

func (m *MockTimerProcessor) Dump() []service.StaleSkipTimerSignal

Dump mocks base method.

func (*MockTimerProcessor) EXPECT added in v1.19.0 

func (m *MockTimerProcessor) EXPECT() *MockTimerProcessorMockRecorder

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

func (*MockTimerProcessor) GetTimerInfos added in v1.19.0 

func (m *MockTimerProcessor) GetTimerInfos() map[string][]*service.TimerInfo

GetTimerInfos mocks base method.

func (*MockTimerProcessor) GetTimerStartedUnixTimestamps added in v1.19.0 

func (m *MockTimerProcessor) GetTimerStartedUnixTimestamps() []int64

GetTimerStartedUnixTimestamps mocks base method.

func (*MockTimerProcessor) RemovePendingTimersOfState added in v1.19.0 

func (m *MockTimerProcessor) RemovePendingTimersOfState(stateExeId string)

RemovePendingTimersOfState mocks base method.

func (*MockTimerProcessor) RetryStaleSkipTimer added in v1.19.0 

func (m *MockTimerProcessor) RetryStaleSkipTimer() bool

RetryStaleSkipTimer mocks base method.

func (*MockTimerProcessor) SkipTimer added in v1.19.0 

func (m *MockTimerProcessor) SkipTimer(stateExeId, timerId string, timerIdx int) bool

SkipTimer mocks base method.

func (*MockTimerProcessor) WaitForTimerFiredOrSkipped added in v1.19.0 

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

WaitForTimerFiredOrSkipped mocks base method.

type MockTimerProcessorMockRecorder added in v1.19.0 

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

MockTimerProcessorMockRecorder is the mock recorder for MockTimerProcessor.

func (*MockTimerProcessorMockRecorder) AddTimers added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) AddTimers(stateExeId, commands, completedTimerCmds interface{}) *gomock.Call

AddTimers indicates an expected call of AddTimers.

func (*MockTimerProcessorMockRecorder) Dump added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) Dump() *gomock.Call

Dump indicates an expected call of Dump.

func (*MockTimerProcessorMockRecorder) GetTimerInfos added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) GetTimerInfos() *gomock.Call

GetTimerInfos indicates an expected call of GetTimerInfos.

func (*MockTimerProcessorMockRecorder) GetTimerStartedUnixTimestamps added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) GetTimerStartedUnixTimestamps() *gomock.Call

GetTimerStartedUnixTimestamps indicates an expected call of GetTimerStartedUnixTimestamps.

func (*MockTimerProcessorMockRecorder) RemovePendingTimersOfState added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) RemovePendingTimersOfState(stateExeId interface{}) *gomock.Call

RemovePendingTimersOfState indicates an expected call of RemovePendingTimersOfState.

func (*MockTimerProcessorMockRecorder) RetryStaleSkipTimer added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) RetryStaleSkipTimer() *gomock.Call

RetryStaleSkipTimer indicates an expected call of RetryStaleSkipTimer.

func (*MockTimerProcessorMockRecorder) SkipTimer added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) SkipTimer(stateExeId, timerId, timerIdx interface{}) *gomock.Call

SkipTimer indicates an expected call of SkipTimer.

func (*MockTimerProcessorMockRecorder) WaitForTimerFiredOrSkipped added in v1.19.0 

func (mr *MockTimerProcessorMockRecorder) WaitForTimerFiredOrSkipped(ctx, stateExeId, timerIdx, cancelWaiting interface{}) *gomock.Call

WaitForTimerFiredOrSkipped indicates an expected call of WaitForTimerFiredOrSkipped.

type MockUnifiedContext 

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

MockUnifiedContext is a mock of UnifiedContext interface.

func NewMockUnifiedContext 

func NewMockUnifiedContext(ctrl *gomock.Controller) *MockUnifiedContext

NewMockUnifiedContext creates a new mock instance.

func (*MockUnifiedContext) EXPECT 

func (m *MockUnifiedContext) EXPECT() *MockUnifiedContextMockRecorder

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

func (*MockUnifiedContext) GetContext 

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

GetContext mocks base method.

type MockUnifiedContextMockRecorder 

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

MockUnifiedContextMockRecorder is the mock recorder for MockUnifiedContext.

func (*MockUnifiedContextMockRecorder) GetContext 

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

GetContext indicates an expected call of GetContext.

type MockUnifiedLogger 

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

MockUnifiedLogger is a mock of UnifiedLogger interface.

func NewMockUnifiedLogger 

func NewMockUnifiedLogger(ctrl *gomock.Controller) *MockUnifiedLogger

NewMockUnifiedLogger creates a new mock instance.

func (*MockUnifiedLogger) Debug 

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

Debug mocks base method.

func (*MockUnifiedLogger) EXPECT 

func (m *MockUnifiedLogger) EXPECT() *MockUnifiedLoggerMockRecorder

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

func (*MockUnifiedLogger) Error 

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

Error mocks base method.

func (*MockUnifiedLogger) Info 

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

Info mocks base method.

func (*MockUnifiedLogger) Warn 

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

Warn mocks base method.

type MockUnifiedLoggerMockRecorder 

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

MockUnifiedLoggerMockRecorder is the mock recorder for MockUnifiedLogger.

func (*MockUnifiedLoggerMockRecorder) Debug 

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

Debug indicates an expected call of Debug.

func (*MockUnifiedLoggerMockRecorder) Error 

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

Error indicates an expected call of Error.

func (*MockUnifiedLoggerMockRecorder) Info 

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

Info indicates an expected call of Info.

func (*MockUnifiedLoggerMockRecorder) Warn 

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

Warn indicates an expected call of Warn.

type MockWorkflowProvider 

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

MockWorkflowProvider is a mock of WorkflowProvider interface.

func NewMockWorkflowProvider 

func NewMockWorkflowProvider(ctrl *gomock.Controller) *MockWorkflowProvider

NewMockWorkflowProvider creates a new mock instance.

func (*MockWorkflowProvider) Await 

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

Await mocks base method.

func (*MockWorkflowProvider) EXPECT 

func (m *MockWorkflowProvider) EXPECT() *MockWorkflowProviderMockRecorder

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

func (*MockWorkflowProvider) ExecuteActivity 

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

ExecuteActivity mocks base method.

func (*MockWorkflowProvider) ExecuteLocalActivity added in v1.19.0 

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

ExecuteLocalActivity mocks base method.

func (*MockWorkflowProvider) ExtendContextWithValue 

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

ExtendContextWithValue mocks base method.

func (*MockWorkflowProvider) GetBackendType 

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

GetBackendType mocks base method.

func (*MockWorkflowProvider) GetContextValue 

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

GetContextValue mocks base method.

func (*MockWorkflowProvider) GetLogger 

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

GetLogger mocks base method.

func (*MockWorkflowProvider) GetPendingThreadNames 

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

GetPendingThreadNames mocks base method.

func (*MockWorkflowProvider) GetSearchAttributes 

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

GetSearchAttributes mocks base method.

func (*MockWorkflowProvider) GetSignalChannel 

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

GetSignalChannel mocks base method.

func (*MockWorkflowProvider) GetThreadCount 

func (m *MockWorkflowProvider) GetThreadCount() int

GetThreadCount mocks base method.

func (*MockWorkflowProvider) GetUnhandledSignalNames 

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

GetUnhandledSignalNames mocks base method.

func (*MockWorkflowProvider) GetVersion 

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

GetVersion mocks base method.

func (*MockWorkflowProvider) GetWorkflowInfo 

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

GetWorkflowInfo mocks base method.

func (*MockWorkflowProvider) GoNamed 

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

GoNamed mocks base method.

func (*MockWorkflowProvider) IsApplicationError 

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

IsApplicationError mocks base method.

func (*MockWorkflowProvider) IsReplaying 

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

IsReplaying mocks base method.

func (*MockWorkflowProvider) NewApplicationError 

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

NewApplicationError mocks base method.

func (*MockWorkflowProvider) NewInterpreterContinueAsNewError 

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

NewInterpreterContinueAsNewError mocks base method.

func (*MockWorkflowProvider) NewTimer 

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

NewTimer mocks base method.

func (*MockWorkflowProvider) Now 

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

Now mocks base method.

func (*MockWorkflowProvider) SetQueryHandler 

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

SetQueryHandler mocks base method.

func (*MockWorkflowProvider) SetRpcUpdateHandler 

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

SetRpcUpdateHandler mocks base method.

func (*MockWorkflowProvider) Sleep 

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

Sleep mocks base method.

func (*MockWorkflowProvider) UpsertMemo 

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

UpsertMemo mocks base method.

func (*MockWorkflowProvider) UpsertSearchAttributes 

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

UpsertSearchAttributes mocks base method.

func (*MockWorkflowProvider) WithActivityOptions 

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

WithActivityOptions mocks base method.

type MockWorkflowProviderMockRecorder 

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

MockWorkflowProviderMockRecorder is the mock recorder for MockWorkflowProvider.

func (*MockWorkflowProviderMockRecorder) Await 

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

Await indicates an expected call of Await.

func (*MockWorkflowProviderMockRecorder) ExecuteActivity 

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

ExecuteActivity indicates an expected call of ExecuteActivity.

func (*MockWorkflowProviderMockRecorder) ExecuteLocalActivity added in v1.19.0 

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

ExecuteLocalActivity indicates an expected call of ExecuteLocalActivity.

func (*MockWorkflowProviderMockRecorder) ExtendContextWithValue 

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

ExtendContextWithValue indicates an expected call of ExtendContextWithValue.

func (*MockWorkflowProviderMockRecorder) GetBackendType 

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

GetBackendType indicates an expected call of GetBackendType.

func (*MockWorkflowProviderMockRecorder) GetContextValue 

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

GetContextValue indicates an expected call of GetContextValue.

func (*MockWorkflowProviderMockRecorder) GetLogger 

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

GetLogger indicates an expected call of GetLogger.

func (*MockWorkflowProviderMockRecorder) GetPendingThreadNames 

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

GetPendingThreadNames indicates an expected call of GetPendingThreadNames.

func (*MockWorkflowProviderMockRecorder) GetSearchAttributes 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockWorkflowProviderMockRecorder) GetSignalChannel 

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

GetSignalChannel indicates an expected call of GetSignalChannel.

func (*MockWorkflowProviderMockRecorder) GetThreadCount 

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

GetThreadCount indicates an expected call of GetThreadCount.

func (*MockWorkflowProviderMockRecorder) GetUnhandledSignalNames 

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

GetUnhandledSignalNames indicates an expected call of GetUnhandledSignalNames.

func (*MockWorkflowProviderMockRecorder) GetVersion 

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

GetVersion indicates an expected call of GetVersion.

func (*MockWorkflowProviderMockRecorder) GetWorkflowInfo 

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

GetWorkflowInfo indicates an expected call of GetWorkflowInfo.

func (*MockWorkflowProviderMockRecorder) GoNamed 

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

GoNamed indicates an expected call of GoNamed.

func (*MockWorkflowProviderMockRecorder) IsApplicationError 

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

IsApplicationError indicates an expected call of IsApplicationError.

func (*MockWorkflowProviderMockRecorder) IsReplaying 

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

IsReplaying indicates an expected call of IsReplaying.

func (*MockWorkflowProviderMockRecorder) NewApplicationError 

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

NewApplicationError indicates an expected call of NewApplicationError.

func (*MockWorkflowProviderMockRecorder) NewInterpreterContinueAsNewError 

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

NewInterpreterContinueAsNewError indicates an expected call of NewInterpreterContinueAsNewError.

func (*MockWorkflowProviderMockRecorder) NewTimer 

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

NewTimer indicates an expected call of NewTimer.

func (*MockWorkflowProviderMockRecorder) Now 

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

Now indicates an expected call of Now.

func (*MockWorkflowProviderMockRecorder) SetQueryHandler 

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

SetQueryHandler indicates an expected call of SetQueryHandler.

func (*MockWorkflowProviderMockRecorder) SetRpcUpdateHandler 

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

SetRpcUpdateHandler indicates an expected call of SetRpcUpdateHandler.

func (*MockWorkflowProviderMockRecorder) Sleep 

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

Sleep indicates an expected call of Sleep.

func (*MockWorkflowProviderMockRecorder) UpsertMemo 

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

UpsertMemo indicates an expected call of UpsertMemo.

func (*MockWorkflowProviderMockRecorder) UpsertSearchAttributes 

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

UpsertSearchAttributes indicates an expected call of UpsertSearchAttributes.

func (*MockWorkflowProviderMockRecorder) WithActivityOptions 

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

WithActivityOptions indicates an expected call of WithActivityOptions.

type ReceiveChannel 

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

type TimerProcessor 

type TimerProcessor interface {
	Dump() []service.StaleSkipTimerSignal
	SkipTimer(stateExeId string, timerId string, timerIdx int) bool
	RetryStaleSkipTimer() bool
	WaitForTimerFiredOrSkipped(ctx UnifiedContext, stateExeId string, timerIdx int, cancelWaiting *bool) service.InternalTimerStatus
	RemovePendingTimersOfState(stateExeId string)
	AddTimers(stateExeId string, commands []iwfidl.TimerCommand, completedTimerCmds map[int]service.InternalTimerStatus)
	GetTimerInfos() map[string][]*service.TimerInfo
	GetTimerStartedUnixTimestamps() []int64
}

type UnifiedContext 

type UnifiedContext interface {
	GetContext() interface{}
}

func NewUnifiedContext 

func NewUnifiedContext(ctx interface{}) UnifiedContext

type UnifiedLogger 

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 

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

type UnifiedRpcValidator 

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

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
	CurrentRunID             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)
	ExecuteLocalActivity(
		valuePtr interface{}, 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
}

Source Files

View all Source files

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.