Documentation ¶
Overview ¶
Package engine is a generated GoMock package.
Index ¶
- type Engine
- type MockEngine
- func (m *MockEngine) CountDLQMessages(ctx context.Context, forceFetch bool) (map[string]int64, error)
- func (m *MockEngine) DescribeMutableState(ctx context.Context, request *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)
- func (m *MockEngine) DescribeTimerQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)
- func (m *MockEngine) DescribeTransferQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error)
- func (m *MockEngine) DescribeWorkflowExecution(ctx context.Context, request *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
- func (m *MockEngine) EXPECT() *MockEngineMockRecorder
- func (m *MockEngine) GetDLQReplicationMessages(ctx context.Context, taskInfos []*types.ReplicationTaskInfo) ([]*types.ReplicationTask, error)
- func (m *MockEngine) GetMutableState(ctx context.Context, request *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)
- func (m *MockEngine) GetReplicationMessages(ctx context.Context, pollingCluster string, lastReadMessageID int64) (*types.ReplicationMessages, error)
- func (m *MockEngine) MergeDLQMessages(ctx context.Context, messagesRequest *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
- func (m *MockEngine) NotifyNewHistoryEvent(event *events.Notification)
- func (m *MockEngine) NotifyNewReplicationTasks(info *common.NotifyTaskInfo)
- func (m *MockEngine) NotifyNewTimerTasks(info *common.NotifyTaskInfo)
- func (m *MockEngine) NotifyNewTransferTasks(info *common.NotifyTaskInfo)
- func (m *MockEngine) PollMutableState(ctx context.Context, request *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)
- func (m *MockEngine) PurgeDLQMessages(ctx context.Context, messagesRequest *types.PurgeDLQMessagesRequest) error
- func (m *MockEngine) QueryWorkflow(ctx context.Context, request *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)
- func (m *MockEngine) ReadDLQMessages(ctx context.Context, messagesRequest *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
- func (m *MockEngine) ReapplyEvents(ctx context.Context, domainUUID, workflowID, runID string, ...) error
- func (m *MockEngine) RecordActivityTaskHeartbeat(ctx context.Context, request *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockEngine) RecordActivityTaskStarted(ctx context.Context, request *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)
- func (m *MockEngine) RecordChildExecutionCompleted(ctx context.Context, request *types.RecordChildExecutionCompletedRequest) error
- func (m *MockEngine) RecordDecisionTaskStarted(ctx context.Context, request *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)
- func (m *MockEngine) RefreshWorkflowTasks(ctx context.Context, domainUUID string, execution types.WorkflowExecution) error
- func (m *MockEngine) RemoveSignalMutableState(ctx context.Context, request *types.RemoveSignalMutableStateRequest) error
- func (m *MockEngine) ReplicateEventsV2(ctx context.Context, request *types.ReplicateEventsV2Request) error
- func (m *MockEngine) RequestCancelWorkflowExecution(ctx context.Context, ...) error
- func (m *MockEngine) ResetStickyTaskList(ctx context.Context, resetRequest *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)
- func (m *MockEngine) ResetTimerQueue(ctx context.Context, clusterName string) error
- func (m *MockEngine) ResetTransferQueue(ctx context.Context, clusterName string) error
- func (m *MockEngine) ResetWorkflowExecution(ctx context.Context, request *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
- func (m *MockEngine) RespondActivityTaskCanceled(ctx context.Context, request *types.HistoryRespondActivityTaskCanceledRequest) error
- func (m *MockEngine) RespondActivityTaskCompleted(ctx context.Context, request *types.HistoryRespondActivityTaskCompletedRequest) error
- func (m *MockEngine) RespondActivityTaskFailed(ctx context.Context, request *types.HistoryRespondActivityTaskFailedRequest) error
- func (m *MockEngine) RespondDecisionTaskCompleted(ctx context.Context, request *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
- func (m *MockEngine) RespondDecisionTaskFailed(ctx context.Context, request *types.HistoryRespondDecisionTaskFailedRequest) error
- func (m *MockEngine) ScheduleDecisionTask(ctx context.Context, request *types.ScheduleDecisionTaskRequest) error
- func (m *MockEngine) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockEngine) SignalWorkflowExecution(ctx context.Context, request *types.HistorySignalWorkflowExecutionRequest) error
- func (m *MockEngine) Start()
- func (m *MockEngine) StartWorkflowExecution(ctx context.Context, request *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockEngine) Stop()
- func (m *MockEngine) SyncActivity(ctx context.Context, request *types.SyncActivityRequest) error
- func (m *MockEngine) SyncShardStatus(ctx context.Context, request *types.SyncShardStatusRequest) error
- func (m *MockEngine) TerminateWorkflowExecution(ctx context.Context, request *types.HistoryTerminateWorkflowExecutionRequest) error
- type MockEngineMockRecorder
- func (mr *MockEngineMockRecorder) CountDLQMessages(ctx, forceFetch interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeTimerQueue(ctx, clusterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeTransferQueue(ctx, clusterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) DescribeWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetDLQReplicationMessages(ctx, taskInfos interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetReplicationMessages(ctx, pollingCluster, lastReadMessageID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) MergeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewHistoryEvent(event interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewReplicationTasks(info interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewTimerTasks(info interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) NotifyNewTransferTasks(info interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) PollMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) PurgeDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) QueryWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReadDLQMessages(ctx, messagesRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReapplyEvents(ctx, domainUUID, workflowID, runID, events interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskHeartbeat(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordActivityTaskStarted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordChildExecutionCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RecordDecisionTaskStarted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RefreshWorkflowTasks(ctx, domainUUID, execution interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RemoveSignalMutableState(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ReplicateEventsV2(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RequestCancelWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetStickyTaskList(ctx, resetRequest interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetTimerQueue(ctx, clusterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetTransferQueue(ctx, clusterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCanceled(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondActivityTaskFailed(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondDecisionTaskCompleted(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RespondDecisionTaskFailed(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ScheduleDecisionTask(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWithStartWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SignalWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) Start() *gomock.Call
- func (mr *MockEngineMockRecorder) StartWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) Stop() *gomock.Call
- func (mr *MockEngineMockRecorder) SyncActivity(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) SyncShardStatus(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) TerminateWorkflowExecution(ctx, request interface{}) *gomock.Call
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) 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 DescribeTransferQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error) DescribeTimerQueue(ctx context.Context, clusterName string) (*types.DescribeQueueResponse, error) NotifyNewHistoryEvent(event *events.Notification) NotifyNewTransferTasks(info *hcommon.NotifyTaskInfo) NotifyNewTimerTasks(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) 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) 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) 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) 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) 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) StartWorkflowExecution ¶
func (m *MockEngine) StartWorkflowExecution(ctx context.Context, request *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
StartWorkflowExecution 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) 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) 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) 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) 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) 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.