engine

package
v1.2.6-prerelease2 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package engine is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Engine 

type Engine interface {
	common.Daemon

	StartWorkflowExecution(ctx context.Context, request *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	GetMutableState(ctx context.Context, request *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)
	PollMutableState(ctx context.Context, request *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)
	DescribeMutableState(ctx context.Context, request *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)
	ResetStickyTaskList(ctx context.Context, resetRequest *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)
	DescribeWorkflowExecution(ctx context.Context, request *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
	RecordDecisionTaskStarted(ctx context.Context, request *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)
	RecordActivityTaskStarted(ctx context.Context, request *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)
	RespondDecisionTaskCompleted(ctx context.Context, request *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(ctx context.Context, request *types.HistoryRespondDecisionTaskFailedRequest) error
	RespondActivityTaskCompleted(ctx context.Context, request *types.HistoryRespondActivityTaskCompletedRequest) error
	RespondActivityTaskFailed(ctx context.Context, request *types.HistoryRespondActivityTaskFailedRequest) error
	RespondActivityTaskCanceled(ctx context.Context, request *types.HistoryRespondActivityTaskCanceledRequest) error
	RecordActivityTaskHeartbeat(ctx context.Context, request *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
	RequestCancelWorkflowExecution(ctx context.Context, request *types.HistoryRequestCancelWorkflowExecutionRequest) error
	SignalWorkflowExecution(ctx context.Context, request *types.HistorySignalWorkflowExecutionRequest) error
	SignalWithStartWorkflowExecution(ctx context.Context, request *types.HistorySignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	RemoveSignalMutableState(ctx context.Context, request *types.RemoveSignalMutableStateRequest) error
	TerminateWorkflowExecution(ctx context.Context, request *types.HistoryTerminateWorkflowExecutionRequest) error
	ResetWorkflowExecution(ctx context.Context, request *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
	ScheduleDecisionTask(ctx context.Context, request *types.ScheduleDecisionTaskRequest) error
	RecordChildExecutionCompleted(ctx context.Context, request *types.RecordChildExecutionCompletedRequest) error
	ReplicateEventsV2(ctx context.Context, request *types.ReplicateEventsV2Request) error
	SyncShardStatus(ctx context.Context, request *types.SyncShardStatusRequest) error
	SyncActivity(ctx context.Context, request *types.SyncActivityRequest) error
	GetReplicationMessages(ctx context.Context, pollingCluster string, lastReadMessageID int64) (*types.ReplicationMessages, error)
	GetDLQReplicationMessages(ctx context.Context, taskInfos []*types.ReplicationTaskInfo) ([]*types.ReplicationTask, error)
	GetCrossClusterTasks(ctx context.Context, targetCluster string) ([]*types.CrossClusterTaskRequest, error)
	RespondCrossClusterTasksCompleted(ctx context.Context, targetCluster string, responses []*types.CrossClusterTaskResponse) error
	QueryWorkflow(ctx context.Context, request *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)
	ReapplyEvents(ctx context.Context, domainUUID string, workflowID string, runID string, events []*types.HistoryEvent) error
	CountDLQMessages(ctx context.Context, forceFetch bool) (map[string]int64, error)
	ReadDLQMessages(ctx context.Context, messagesRequest *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
	PurgeDLQMessages(ctx context.Context, messagesRequest *types.PurgeDLQMessagesRequest) error
	MergeDLQMessages(ctx context.Context, messagesRequest *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
	RefreshWorkflowTasks(ctx context.Context, domainUUID string, execution types.WorkflowExecution) error
	ResetTransferQueue(ctx context.Context, clusterName string) error
	ResetTimerQueue(ctx context.Context, clusterName string) error
	ResetCrossClusterQueue(ctx context.Context, clusterName string) error
	DescribeTransferQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)
	DescribeTimerQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)
	DescribeCrossClusterQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)

	NotifyNewHistoryEvent(event *events.Notification)
	NotifyNewTransferTasks(info *hcommon.NotifyTaskInfo)
	NotifyNewTimerTasks(info *hcommon.NotifyTaskInfo)
	NotifyNewCrossClusterTasks(info *hcommon.NotifyTaskInfo)
	NotifyNewReplicationTasks(info *hcommon.NotifyTaskInfo)
}

Engine represents an interface for managing workflow execution history.

type MockEngine 

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

MockEngine is a mock of Engine interface.

func NewMockEngine 

func NewMockEngine(ctrl *gomock.Controller) *MockEngine

NewMockEngine creates a new mock instance.

func (*MockEngine) CountDLQMessages added in v0.25.0 

func (m *MockEngine) CountDLQMessages(ctx context.Context, forceFetch bool) (map[string]int64, error)

CountDLQMessages mocks base method.

func (*MockEngine) DescribeCrossClusterQueue added in v0.23.1 

func (m *MockEngine) DescribeCrossClusterQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)

DescribeCrossClusterQueue mocks base method.

func (*MockEngine) DescribeMutableState 

func (m *MockEngine) DescribeMutableState(ctx context.Context, request *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method.

func (*MockEngine) DescribeTimerQueue added in v0.15.0 

func (m *MockEngine) DescribeTimerQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)

DescribeTimerQueue mocks base method.

func (*MockEngine) DescribeTransferQueue added in v0.15.0 

func (m *MockEngine) DescribeTransferQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)

DescribeTransferQueue mocks base method.

func (*MockEngine) DescribeWorkflowExecution 

func (m *MockEngine) DescribeWorkflowExecution(ctx context.Context, request *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockEngine) EXPECT 

func (m *MockEngine) EXPECT() *MockEngineMockRecorder

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

func (*MockEngine) GetCrossClusterTasks added in v0.23.1 

func (m *MockEngine) GetCrossClusterTasks(ctx context.Context, targetCluster string) ([]*types.CrossClusterTaskRequest, error)

GetCrossClusterTasks mocks base method.

func (*MockEngine) GetDLQReplicationMessages 

func (m *MockEngine) GetDLQReplicationMessages(ctx context.Context, taskInfos []*types.ReplicationTaskInfo) ([]*types.ReplicationTask, error)

GetDLQReplicationMessages mocks base method.

func (*MockEngine) GetMutableState 

func (m *MockEngine) GetMutableState(ctx context.Context, request *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)

GetMutableState mocks base method.

func (*MockEngine) GetReplicationMessages 

func (m *MockEngine) GetReplicationMessages(ctx context.Context, pollingCluster string, lastReadMessageID int64) (*types.ReplicationMessages, error)

GetReplicationMessages mocks base method.

func (*MockEngine) MergeDLQMessages 

func (m *MockEngine) MergeDLQMessages(ctx context.Context, messagesRequest *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method.

func (*MockEngine) NotifyNewCrossClusterTasks added in v0.23.1 

func (m *MockEngine) NotifyNewCrossClusterTasks(info *common.NotifyTaskInfo)

NotifyNewCrossClusterTasks mocks base method.

func (*MockEngine) NotifyNewHistoryEvent 

func (m *MockEngine) NotifyNewHistoryEvent(event *events.Notification)

NotifyNewHistoryEvent mocks base method.

func (*MockEngine) NotifyNewReplicationTasks 

func (m *MockEngine) NotifyNewReplicationTasks(info *common.NotifyTaskInfo)

NotifyNewReplicationTasks mocks base method.

func (*MockEngine) NotifyNewTimerTasks 

func (m *MockEngine) NotifyNewTimerTasks(info *common.NotifyTaskInfo)

NotifyNewTimerTasks mocks base method.

func (*MockEngine) NotifyNewTransferTasks 

func (m *MockEngine) NotifyNewTransferTasks(info *common.NotifyTaskInfo)

NotifyNewTransferTasks mocks base method.

func (*MockEngine) PollMutableState 

func (m *MockEngine) PollMutableState(ctx context.Context, request *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)

PollMutableState mocks base method.

func (*MockEngine) PurgeDLQMessages 

func (m *MockEngine) PurgeDLQMessages(ctx context.Context, messagesRequest *types.PurgeDLQMessagesRequest) error

PurgeDLQMessages mocks base method.

func (*MockEngine) QueryWorkflow 

func (m *MockEngine) QueryWorkflow(ctx context.Context, request *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockEngine) ReadDLQMessages 

func (m *MockEngine) ReadDLQMessages(ctx context.Context, messagesRequest *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)

ReadDLQMessages mocks base method.

func (*MockEngine) ReapplyEvents 

func (m *MockEngine) ReapplyEvents(ctx context.Context, domainUUID, workflowID, runID string, events []*types.HistoryEvent) error

ReapplyEvents mocks base method.

func (*MockEngine) RecordActivityTaskHeartbeat 

func (m *MockEngine) RecordActivityTaskHeartbeat(ctx context.Context, request *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method.

func (*MockEngine) RecordActivityTaskStarted 

func (m *MockEngine) RecordActivityTaskStarted(ctx context.Context, request *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method.

func (*MockEngine) RecordChildExecutionCompleted 

func (m *MockEngine) RecordChildExecutionCompleted(ctx context.Context, request *types.RecordChildExecutionCompletedRequest) error

RecordChildExecutionCompleted mocks base method.

func (*MockEngine) RecordDecisionTaskStarted 

func (m *MockEngine) RecordDecisionTaskStarted(ctx context.Context, request *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted mocks base method.

func (*MockEngine) RefreshWorkflowTasks 

func (m *MockEngine) RefreshWorkflowTasks(ctx context.Context, domainUUID string, execution types.WorkflowExecution) error

RefreshWorkflowTasks mocks base method.

func (*MockEngine) RemoveSignalMutableState 

func (m *MockEngine) RemoveSignalMutableState(ctx context.Context, request *types.RemoveSignalMutableStateRequest) error

RemoveSignalMutableState mocks base method.

func (*MockEngine) ReplicateEventsV2 

func (m *MockEngine) ReplicateEventsV2(ctx context.Context, request *types.ReplicateEventsV2Request) error

ReplicateEventsV2 mocks base method.

func (*MockEngine) RequestCancelWorkflowExecution 

func (m *MockEngine) RequestCancelWorkflowExecution(ctx context.Context, request *types.HistoryRequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution mocks base method.

func (*MockEngine) ResetCrossClusterQueue added in v0.23.1 

func (m *MockEngine) ResetCrossClusterQueue(ctx context.Context, clusterName string) error

ResetCrossClusterQueue mocks base method.

func (*MockEngine) ResetStickyTaskList 

func (m *MockEngine) ResetStickyTaskList(ctx context.Context, resetRequest *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method.

func (*MockEngine) ResetTimerQueue added in v0.15.0 

func (m *MockEngine) ResetTimerQueue(ctx context.Context, clusterName string) error

ResetTimerQueue mocks base method.

func (*MockEngine) ResetTransferQueue added in v0.15.0 

func (m *MockEngine) ResetTransferQueue(ctx context.Context, clusterName string) error

ResetTransferQueue mocks base method.

func (*MockEngine) ResetWorkflowExecution 

func (m *MockEngine) ResetWorkflowExecution(ctx context.Context, request *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockEngine) RespondActivityTaskCanceled 

func (m *MockEngine) RespondActivityTaskCanceled(ctx context.Context, request *types.HistoryRespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled mocks base method.

func (*MockEngine) RespondActivityTaskCompleted 

func (m *MockEngine) RespondActivityTaskCompleted(ctx context.Context, request *types.HistoryRespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted mocks base method.

func (*MockEngine) RespondActivityTaskFailed 

func (m *MockEngine) RespondActivityTaskFailed(ctx context.Context, request *types.HistoryRespondActivityTaskFailedRequest) error

RespondActivityTaskFailed mocks base method.

func (*MockEngine) RespondCrossClusterTasksCompleted added in v0.23.1 

func (m *MockEngine) RespondCrossClusterTasksCompleted(ctx context.Context, targetCluster string, responses []*types.CrossClusterTaskResponse) error

RespondCrossClusterTasksCompleted mocks base method.

func (*MockEngine) RespondDecisionTaskCompleted 

func (m *MockEngine) RespondDecisionTaskCompleted(ctx context.Context, request *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method.

func (*MockEngine) RespondDecisionTaskFailed 

func (m *MockEngine) RespondDecisionTaskFailed(ctx context.Context, request *types.HistoryRespondDecisionTaskFailedRequest) error

RespondDecisionTaskFailed mocks base method.

func (*MockEngine) ScheduleDecisionTask 

func (m *MockEngine) ScheduleDecisionTask(ctx context.Context, request *types.ScheduleDecisionTaskRequest) error

ScheduleDecisionTask mocks base method.

func (*MockEngine) SignalWithStartWorkflowExecution 

func (m *MockEngine) SignalWithStartWorkflowExecution(ctx context.Context, request *types.HistorySignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockEngine) SignalWorkflowExecution 

func (m *MockEngine) SignalWorkflowExecution(ctx context.Context, request *types.HistorySignalWorkflowExecutionRequest) error

SignalWorkflowExecution mocks base method.

func (*MockEngine) Start 

func (m *MockEngine) Start()

Start mocks base method.

func (*MockEngine) StartWorkflowExecution 

func (m *MockEngine) StartWorkflowExecution(ctx context.Context, request *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method.

func (*MockEngine) Stop 

func (m *MockEngine) Stop()

Stop mocks base method.

func (*MockEngine) SyncActivity 

func (m *MockEngine) SyncActivity(ctx context.Context, request *types.SyncActivityRequest) error

SyncActivity mocks base method.

func (*MockEngine) SyncShardStatus 

func (m *MockEngine) SyncShardStatus(ctx context.Context, request *types.SyncShardStatusRequest) error

SyncShardStatus mocks base method.

func (*MockEngine) TerminateWorkflowExecution 

func (m *MockEngine) TerminateWorkflowExecution(ctx context.Context, request *types.HistoryTerminateWorkflowExecutionRequest) error

TerminateWorkflowExecution mocks base method.

type MockEngineMockRecorder 

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

MockEngineMockRecorder is the mock recorder for MockEngine.

func (*MockEngineMockRecorder) CountDLQMessages added in v0.25.0 

func (mr *MockEngineMockRecorder) CountDLQMessages(ctx, forceFetch interface{}) *gomock.Call

CountDLQMessages indicates an expected call of CountDLQMessages.

func (*MockEngineMockRecorder) DescribeCrossClusterQueue added in v0.23.1 

func (mr *MockEngineMockRecorder) DescribeCrossClusterQueue(ctx, clusterName interface{}) *gomock.Call

DescribeCrossClusterQueue indicates an expected call of DescribeCrossClusterQueue.

func (*MockEngineMockRecorder) DescribeMutableState 

func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request interface{}) *gomock.Call

DescribeMutableState indicates an expected call of DescribeMutableState.

func (*MockEngineMockRecorder) DescribeTimerQueue added in v0.15.0 

func (mr *MockEngineMockRecorder) DescribeTimerQueue(ctx, clusterName interface{}) *gomock.Call

DescribeTimerQueue indicates an expected call of DescribeTimerQueue.

func (*MockEngineMockRecorder) DescribeTransferQueue added in v0.15.0 

func (mr *MockEngineMockRecorder) DescribeTransferQueue(ctx, clusterName interface{}) *gomock.Call

DescribeTransferQueue indicates an expected call of DescribeTransferQueue.

func (*MockEngineMockRecorder) DescribeWorkflowExecution 

func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockEngineMockRecorder) GetCrossClusterTasks added in v0.23.1 

func (mr *MockEngineMockRecorder) GetCrossClusterTasks(ctx, targetCluster interface{}) *gomock.Call

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.

func (*MockEngineMockRecorder) GetDLQReplicationMessages 

func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos interface{}) *gomock.Call

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.

func (*MockEngineMockRecorder) GetMutableState 

func (mr *MockEngineMockRecorder) GetMutableState(ctx, request interface{}) *gomock.Call

GetMutableState indicates an expected call of GetMutableState.

func (*MockEngineMockRecorder) GetReplicationMessages 

func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, lastReadMessageID interface{}) *gomock.Call

GetReplicationMessages indicates an expected call of GetReplicationMessages.

func (*MockEngineMockRecorder) MergeDLQMessages 

func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call

MergeDLQMessages indicates an expected call of MergeDLQMessages.

func (*MockEngineMockRecorder) NotifyNewCrossClusterTasks added in v0.23.1 

func (mr *MockEngineMockRecorder) NotifyNewCrossClusterTasks(info interface{}) *gomock.Call

NotifyNewCrossClusterTasks indicates an expected call of NotifyNewCrossClusterTasks.

func (*MockEngineMockRecorder) NotifyNewHistoryEvent 

func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event interface{}) *gomock.Call

NotifyNewHistoryEvent indicates an expected call of NotifyNewHistoryEvent.

func (*MockEngineMockRecorder) NotifyNewReplicationTasks 

func (mr *MockEngineMockRecorder) NotifyNewReplicationTasks(info interface{}) *gomock.Call

NotifyNewReplicationTasks indicates an expected call of NotifyNewReplicationTasks.

func (*MockEngineMockRecorder) NotifyNewTimerTasks 

func (mr *MockEngineMockRecorder) NotifyNewTimerTasks(info interface{}) *gomock.Call

NotifyNewTimerTasks indicates an expected call of NotifyNewTimerTasks.

func (*MockEngineMockRecorder) NotifyNewTransferTasks 

func (mr *MockEngineMockRecorder) NotifyNewTransferTasks(info interface{}) *gomock.Call

NotifyNewTransferTasks indicates an expected call of NotifyNewTransferTasks.

func (*MockEngineMockRecorder) PollMutableState 

func (mr *MockEngineMockRecorder) PollMutableState(ctx, request interface{}) *gomock.Call

PollMutableState indicates an expected call of PollMutableState.

func (*MockEngineMockRecorder) PurgeDLQMessages 

func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call

PurgeDLQMessages indicates an expected call of PurgeDLQMessages.

func (*MockEngineMockRecorder) QueryWorkflow 

func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockEngineMockRecorder) ReadDLQMessages 

func (mr *MockEngineMockRecorder) ReadDLQMessages(ctx, messagesRequest interface{}) *gomock.Call

ReadDLQMessages indicates an expected call of ReadDLQMessages.

func (*MockEngineMockRecorder) ReapplyEvents 

func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, domainUUID, workflowID, runID, events interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockEngineMockRecorder) RecordActivityTaskHeartbeat 

func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockEngineMockRecorder) RecordActivityTaskStarted 

func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request interface{}) *gomock.Call

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.

func (*MockEngineMockRecorder) RecordChildExecutionCompleted 

func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request interface{}) *gomock.Call

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.

func (*MockEngineMockRecorder) RecordDecisionTaskStarted 

func (mr *MockEngineMockRecorder) RecordDecisionTaskStarted(ctx, request interface{}) *gomock.Call

RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted.

func (*MockEngineMockRecorder) RefreshWorkflowTasks 

func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, domainUUID, execution interface{}) *gomock.Call

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockEngineMockRecorder) RemoveSignalMutableState 

func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request interface{}) *gomock.Call

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.

func (*MockEngineMockRecorder) ReplicateEventsV2 

func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request interface{}) *gomock.Call

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.

func (*MockEngineMockRecorder) RequestCancelWorkflowExecution 

func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockEngineMockRecorder) ResetCrossClusterQueue added in v0.23.1 

func (mr *MockEngineMockRecorder) ResetCrossClusterQueue(ctx, clusterName interface{}) *gomock.Call

ResetCrossClusterQueue indicates an expected call of ResetCrossClusterQueue.

func (*MockEngineMockRecorder) ResetStickyTaskList 

func (mr *MockEngineMockRecorder) ResetStickyTaskList(ctx, resetRequest interface{}) *gomock.Call

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockEngineMockRecorder) ResetTimerQueue added in v0.15.0 

func (mr *MockEngineMockRecorder) ResetTimerQueue(ctx, clusterName interface{}) *gomock.Call

ResetTimerQueue indicates an expected call of ResetTimerQueue.

func (*MockEngineMockRecorder) ResetTransferQueue added in v0.15.0 

func (mr *MockEngineMockRecorder) ResetTransferQueue(ctx, clusterName interface{}) *gomock.Call

ResetTransferQueue indicates an expected call of ResetTransferQueue.

func (*MockEngineMockRecorder) ResetWorkflowExecution 

func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockEngineMockRecorder) RespondActivityTaskCanceled 

func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockEngineMockRecorder) RespondActivityTaskCompleted 

func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockEngineMockRecorder) RespondActivityTaskFailed 

func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockEngineMockRecorder) RespondCrossClusterTasksCompleted added in v0.23.1 

func (mr *MockEngineMockRecorder) RespondCrossClusterTasksCompleted(ctx, targetCluster, responses interface{}) *gomock.Call

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.

func (*MockEngineMockRecorder) RespondDecisionTaskCompleted 

func (mr *MockEngineMockRecorder) RespondDecisionTaskCompleted(ctx, request interface{}) *gomock.Call

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockEngineMockRecorder) RespondDecisionTaskFailed 

func (mr *MockEngineMockRecorder) RespondDecisionTaskFailed(ctx, request interface{}) *gomock.Call

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockEngineMockRecorder) ScheduleDecisionTask 

func (mr *MockEngineMockRecorder) ScheduleDecisionTask(ctx, request interface{}) *gomock.Call

ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask.

func (*MockEngineMockRecorder) SignalWithStartWorkflowExecution 

func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockEngineMockRecorder) SignalWorkflowExecution 

func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockEngineMockRecorder) Start 

func (mr *MockEngineMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockEngineMockRecorder) StartWorkflowExecution 

func (mr *MockEngineMockRecorder) StartWorkflowExecution(ctx, request interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockEngineMockRecorder) Stop 

func (mr *MockEngineMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockEngineMockRecorder) SyncActivity 

func (mr *MockEngineMockRecorder) SyncActivity(ctx, request interface{}) *gomock.Call

SyncActivity indicates an expected call of SyncActivity.

func (*MockEngineMockRecorder) SyncShardStatus 

func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request interface{}) *gomock.Call

SyncShardStatus indicates an expected call of SyncShardStatus.

func (*MockEngineMockRecorder) TerminateWorkflowExecution 

func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

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.