handler

package
v1.2.11-prerelease7 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2024 License: MIT Imports: 36 Imported by: 0

Documentation

Overview

Package handler is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler 

type Handler interface {
	// Do not use embeded methods, otherwise, we got the following error from gowrap
	// and we only get this error from history/interface.go, not sure why
	// failed to parse interface declaration: Daemon: target declaration not found
	// service/history/interface.go:22: running "gowrap": exit status 1
	// common.Daemon
	Start()
	Stop()

	PrepareToStop(time.Duration) time.Duration
	Health(context.Context) (*types.HealthStatus, error)
	CloseShard(context.Context, *types.CloseShardRequest) error
	DescribeHistoryHost(context.Context, *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
	DescribeMutableState(context.Context, *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)
	DescribeQueue(context.Context, *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
	DescribeWorkflowExecution(context.Context, *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
	GetCrossClusterTasks(context.Context, *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
	CountDLQMessages(context.Context, *types.CountDLQMessagesRequest) (*types.HistoryCountDLQMessagesResponse, error)
	GetDLQReplicationMessages(context.Context, *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
	GetMutableState(context.Context, *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)
	GetReplicationMessages(context.Context, *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
	MergeDLQMessages(context.Context, *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
	NotifyFailoverMarkers(context.Context, *types.NotifyFailoverMarkersRequest) error
	PollMutableState(context.Context, *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)
	PurgeDLQMessages(context.Context, *types.PurgeDLQMessagesRequest) error
	QueryWorkflow(context.Context, *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)
	ReadDLQMessages(context.Context, *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
	ReapplyEvents(context.Context, *types.HistoryReapplyEventsRequest) error
	RecordActivityTaskHeartbeat(context.Context, *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskStarted(context.Context, *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)
	RecordChildExecutionCompleted(context.Context, *types.RecordChildExecutionCompletedRequest) error
	RecordDecisionTaskStarted(context.Context, *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)
	RefreshWorkflowTasks(context.Context, *types.HistoryRefreshWorkflowTasksRequest) error
	RemoveSignalMutableState(context.Context, *types.RemoveSignalMutableStateRequest) error
	RemoveTask(context.Context, *types.RemoveTaskRequest) error
	ReplicateEventsV2(context.Context, *types.ReplicateEventsV2Request) error
	RequestCancelWorkflowExecution(context.Context, *types.HistoryRequestCancelWorkflowExecutionRequest) error
	ResetQueue(context.Context, *types.ResetQueueRequest) error
	ResetStickyTaskList(context.Context, *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)
	ResetWorkflowExecution(context.Context, *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
	RespondActivityTaskCanceled(context.Context, *types.HistoryRespondActivityTaskCanceledRequest) error
	RespondActivityTaskCompleted(context.Context, *types.HistoryRespondActivityTaskCompletedRequest) error
	RespondActivityTaskFailed(context.Context, *types.HistoryRespondActivityTaskFailedRequest) error
	RespondCrossClusterTasksCompleted(context.Context, *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
	RespondDecisionTaskCompleted(context.Context, *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *types.HistoryRespondDecisionTaskFailedRequest) error
	ScheduleDecisionTask(context.Context, *types.ScheduleDecisionTaskRequest) error
	SignalWithStartWorkflowExecution(context.Context, *types.HistorySignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *types.HistorySignalWorkflowExecutionRequest) error
	StartWorkflowExecution(context.Context, *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
	SyncActivity(context.Context, *types.SyncActivityRequest) error
	SyncShardStatus(context.Context, *types.SyncShardStatusRequest) error
	TerminateWorkflowExecution(context.Context, *types.HistoryTerminateWorkflowExecutionRequest) error
	GetFailoverInfo(context.Context, *types.GetFailoverInfoRequest) (*types.GetFailoverInfoResponse, error)
	RatelimitUpdate(context.Context, *types.RatelimitUpdateRequest) (*types.RatelimitUpdateResponse, error)
}

Handler interface for history service

func NewHandler 

func NewHandler(
	resource resource.Resource,
	config *config.Config,
	wfCache workflowcache.WFCache,
	ratelimitInternalPerWorkflowID dynamicconfig.BoolPropertyFnWithDomainFilter,
) Handler

NewHandler creates a thrift handler for the history service

type MockHandler 

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

MockHandler is a mock of Handler interface.

func NewMockHandler 

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance.

func (*MockHandler) CloseShard 

func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error

CloseShard mocks base method.

func (*MockHandler) CountDLQMessages 

func (m *MockHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.HistoryCountDLQMessagesResponse, error)

CountDLQMessages mocks base method.

func (*MockHandler) DescribeHistoryHost 

func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method.

func (*MockHandler) DescribeMutableState 

func (m *MockHandler) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method.

func (*MockHandler) DescribeQueue 

func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)

DescribeQueue mocks base method.

func (*MockHandler) DescribeWorkflowExecution 

func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockHandler) EXPECT 

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

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

func (*MockHandler) GetCrossClusterTasks 

func (m *MockHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)

GetCrossClusterTasks mocks base method.

func (*MockHandler) GetDLQReplicationMessages 

func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method.

func (*MockHandler) GetFailoverInfo 

func (m *MockHandler) GetFailoverInfo(arg0 context.Context, arg1 *types.GetFailoverInfoRequest) (*types.GetFailoverInfoResponse, error)

GetFailoverInfo mocks base method.

func (*MockHandler) GetMutableState 

func (m *MockHandler) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)

GetMutableState mocks base method.

func (*MockHandler) GetReplicationMessages 

func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method.

func (*MockHandler) Health 

func (m *MockHandler) Health(arg0 context.Context) (*types.HealthStatus, error)

Health mocks base method.

func (*MockHandler) MergeDLQMessages 

func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method.

func (*MockHandler) NotifyFailoverMarkers 

func (m *MockHandler) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest) error

NotifyFailoverMarkers mocks base method.

func (*MockHandler) PollMutableState 

func (m *MockHandler) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)

PollMutableState mocks base method.

func (*MockHandler) PrepareToStop 

func (m *MockHandler) PrepareToStop(arg0 time.Duration) time.Duration

PrepareToStop mocks base method.

func (*MockHandler) PurgeDLQMessages 

func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error

PurgeDLQMessages mocks base method.

func (*MockHandler) QueryWorkflow 

func (m *MockHandler) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockHandler) RatelimitUpdate added in v1.2.10 

func (m *MockHandler) RatelimitUpdate(arg0 context.Context, arg1 *types.RatelimitUpdateRequest) (*types.RatelimitUpdateResponse, error)

RatelimitUpdate mocks base method.

func (*MockHandler) ReadDLQMessages 

func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)

ReadDLQMessages mocks base method.

func (*MockHandler) ReapplyEvents 

func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest) error

ReapplyEvents mocks base method.

func (*MockHandler) RecordActivityTaskHeartbeat 

func (m *MockHandler) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method.

func (*MockHandler) RecordActivityTaskStarted 

func (m *MockHandler) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method.

func (*MockHandler) RecordChildExecutionCompleted 

func (m *MockHandler) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest) error

RecordChildExecutionCompleted mocks base method.

func (*MockHandler) RecordDecisionTaskStarted 

func (m *MockHandler) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)

RecordDecisionTaskStarted mocks base method.

func (*MockHandler) RefreshWorkflowTasks 

func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest) error

RefreshWorkflowTasks mocks base method.

func (*MockHandler) RemoveSignalMutableState 

func (m *MockHandler) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest) error

RemoveSignalMutableState mocks base method.

func (*MockHandler) RemoveTask 

func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error

RemoveTask mocks base method.

func (*MockHandler) ReplicateEventsV2 

func (m *MockHandler) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request) error

ReplicateEventsV2 mocks base method.

func (*MockHandler) RequestCancelWorkflowExecution 

func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest) error

RequestCancelWorkflowExecution mocks base method.

func (*MockHandler) ResetQueue 

func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error

ResetQueue mocks base method.

func (*MockHandler) ResetStickyTaskList 

func (m *MockHandler) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)

ResetStickyTaskList mocks base method.

func (*MockHandler) ResetWorkflowExecution 

func (m *MockHandler) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockHandler) RespondActivityTaskCanceled 

func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest) error

RespondActivityTaskCanceled mocks base method.

func (*MockHandler) RespondActivityTaskCompleted 

func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest) error

RespondActivityTaskCompleted mocks base method.

func (*MockHandler) RespondActivityTaskFailed 

func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest) error

RespondActivityTaskFailed mocks base method.

func (*MockHandler) RespondCrossClusterTasksCompleted 

func (m *MockHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)

RespondCrossClusterTasksCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskCompleted 

func (m *MockHandler) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)

RespondDecisionTaskCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskFailed 

func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest) error

RespondDecisionTaskFailed mocks base method.

func (*MockHandler) ScheduleDecisionTask 

func (m *MockHandler) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest) error

ScheduleDecisionTask mocks base method.

func (*MockHandler) SignalWithStartWorkflowExecution 

func (m *MockHandler) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockHandler) SignalWorkflowExecution 

func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest) error

SignalWorkflowExecution mocks base method.

func (*MockHandler) Start 

func (m *MockHandler) Start()

Start mocks base method.

func (*MockHandler) StartWorkflowExecution 

func (m *MockHandler) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method.

func (*MockHandler) Stop 

func (m *MockHandler) Stop()

Stop mocks base method.

func (*MockHandler) SyncActivity 

func (m *MockHandler) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest) error

SyncActivity mocks base method.

func (*MockHandler) SyncShardStatus 

func (m *MockHandler) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest) error

SyncShardStatus mocks base method.

func (*MockHandler) TerminateWorkflowExecution 

func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest) error

TerminateWorkflowExecution mocks base method.

type MockHandlerMockRecorder 

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

MockHandlerMockRecorder is the mock recorder for MockHandler.

func (*MockHandlerMockRecorder) CloseShard 

func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call

CloseShard indicates an expected call of CloseShard.

func (*MockHandlerMockRecorder) CountDLQMessages 

func (mr *MockHandlerMockRecorder) CountDLQMessages(arg0, arg1 interface{}) *gomock.Call

CountDLQMessages indicates an expected call of CountDLQMessages.

func (*MockHandlerMockRecorder) DescribeHistoryHost 

func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call

DescribeHistoryHost indicates an expected call of DescribeHistoryHost.

func (*MockHandlerMockRecorder) DescribeMutableState 

func (mr *MockHandlerMockRecorder) DescribeMutableState(arg0, arg1 interface{}) *gomock.Call

DescribeMutableState indicates an expected call of DescribeMutableState.

func (*MockHandlerMockRecorder) DescribeQueue 

func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call

DescribeQueue indicates an expected call of DescribeQueue.

func (*MockHandlerMockRecorder) DescribeWorkflowExecution 

func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockHandlerMockRecorder) GetCrossClusterTasks 

func (mr *MockHandlerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.

func (*MockHandlerMockRecorder) GetDLQReplicationMessages 

func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.

func (*MockHandlerMockRecorder) GetFailoverInfo 

func (mr *MockHandlerMockRecorder) GetFailoverInfo(arg0, arg1 interface{}) *gomock.Call

GetFailoverInfo indicates an expected call of GetFailoverInfo.

func (*MockHandlerMockRecorder) GetMutableState 

func (mr *MockHandlerMockRecorder) GetMutableState(arg0, arg1 interface{}) *gomock.Call

GetMutableState indicates an expected call of GetMutableState.

func (*MockHandlerMockRecorder) GetReplicationMessages 

func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call

GetReplicationMessages indicates an expected call of GetReplicationMessages.

func (*MockHandlerMockRecorder) Health 

func (mr *MockHandlerMockRecorder) Health(arg0 interface{}) *gomock.Call

Health indicates an expected call of Health.

func (*MockHandlerMockRecorder) MergeDLQMessages 

func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call

MergeDLQMessages indicates an expected call of MergeDLQMessages.

func (*MockHandlerMockRecorder) NotifyFailoverMarkers 

func (mr *MockHandlerMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}) *gomock.Call

NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers.

func (*MockHandlerMockRecorder) PollMutableState 

func (mr *MockHandlerMockRecorder) PollMutableState(arg0, arg1 interface{}) *gomock.Call

PollMutableState indicates an expected call of PollMutableState.

func (*MockHandlerMockRecorder) PrepareToStop 

func (mr *MockHandlerMockRecorder) PrepareToStop(arg0 interface{}) *gomock.Call

PrepareToStop indicates an expected call of PrepareToStop.

func (*MockHandlerMockRecorder) PurgeDLQMessages 

func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call

PurgeDLQMessages indicates an expected call of PurgeDLQMessages.

func (*MockHandlerMockRecorder) QueryWorkflow 

func (mr *MockHandlerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockHandlerMockRecorder) RatelimitUpdate added in v1.2.10 

func (mr *MockHandlerMockRecorder) RatelimitUpdate(arg0, arg1 interface{}) *gomock.Call

RatelimitUpdate indicates an expected call of RatelimitUpdate.

func (*MockHandlerMockRecorder) ReadDLQMessages 

func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call

ReadDLQMessages indicates an expected call of ReadDLQMessages.

func (*MockHandlerMockRecorder) ReapplyEvents 

func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat 

func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockHandlerMockRecorder) RecordActivityTaskStarted 

func (mr *MockHandlerMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}) *gomock.Call

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.

func (*MockHandlerMockRecorder) RecordChildExecutionCompleted 

func (mr *MockHandlerMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}) *gomock.Call

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.

func (*MockHandlerMockRecorder) RecordDecisionTaskStarted 

func (mr *MockHandlerMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}) *gomock.Call

RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted.

func (*MockHandlerMockRecorder) RefreshWorkflowTasks 

func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockHandlerMockRecorder) RemoveSignalMutableState 

func (mr *MockHandlerMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}) *gomock.Call

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.

func (*MockHandlerMockRecorder) RemoveTask 

func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call

RemoveTask indicates an expected call of RemoveTask.

func (*MockHandlerMockRecorder) ReplicateEventsV2 

func (mr *MockHandlerMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}) *gomock.Call

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.

func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution 

func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockHandlerMockRecorder) ResetQueue 

func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call

ResetQueue indicates an expected call of ResetQueue.

func (*MockHandlerMockRecorder) ResetStickyTaskList 

func (mr *MockHandlerMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}) *gomock.Call

ResetStickyTaskList indicates an expected call of ResetStickyTaskList.

func (*MockHandlerMockRecorder) ResetWorkflowExecution 

func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockHandlerMockRecorder) RespondActivityTaskCanceled 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockHandlerMockRecorder) RespondActivityTaskCompleted 

func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockHandlerMockRecorder) RespondActivityTaskFailed 

func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockHandlerMockRecorder) RespondCrossClusterTasksCompleted 

func (mr *MockHandlerMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}) *gomock.Call

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.

func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted 

func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}) *gomock.Call

RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.

func (*MockHandlerMockRecorder) RespondDecisionTaskFailed 

func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}) *gomock.Call

RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.

func (*MockHandlerMockRecorder) ScheduleDecisionTask 

func (mr *MockHandlerMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}) *gomock.Call

ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask.

func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution 

func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockHandlerMockRecorder) SignalWorkflowExecution 

func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockHandlerMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*MockHandlerMockRecorder) StartWorkflowExecution 

func (mr *MockHandlerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockHandlerMockRecorder) Stop 

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

Stop indicates an expected call of Stop.

func (*MockHandlerMockRecorder) SyncActivity 

func (mr *MockHandlerMockRecorder) SyncActivity(arg0, arg1 interface{}) *gomock.Call

SyncActivity indicates an expected call of SyncActivity.

func (*MockHandlerMockRecorder) SyncShardStatus 

func (mr *MockHandlerMockRecorder) SyncShardStatus(arg0, arg1 interface{}) *gomock.Call

SyncShardStatus indicates an expected call of SyncShardStatus.

func (*MockHandlerMockRecorder) TerminateWorkflowExecution 

func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(arg0, arg1 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.