handler

package
v1.2.10-prerelease4 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: MIT Imports: 35 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

CountDLQMessages mocks base method.

func (*MockHandler) DescribeHistoryHost

DescribeHistoryHost mocks base method.

func (*MockHandler) DescribeMutableState

DescribeMutableState mocks base method.

func (*MockHandler) DescribeQueue

DescribeQueue mocks base method.

func (*MockHandler) DescribeWorkflowExecution

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

GetCrossClusterTasks mocks base method.

func (*MockHandler) GetDLQReplicationMessages

GetDLQReplicationMessages mocks base method.

func (*MockHandler) GetFailoverInfo

GetFailoverInfo mocks base method.

func (*MockHandler) GetMutableState

GetMutableState mocks base method.

func (*MockHandler) GetReplicationMessages

GetReplicationMessages mocks base method.

func (*MockHandler) Health

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

Health mocks base method.

func (*MockHandler) MergeDLQMessages

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

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

QueryWorkflow mocks base method.

func (*MockHandler) RatelimitUpdate added in v1.2.10

RatelimitUpdate mocks base method.

func (*MockHandler) ReadDLQMessages

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

RecordActivityTaskHeartbeat mocks base method.

func (*MockHandler) RecordActivityTaskStarted

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

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

ResetStickyTaskList mocks base method.

func (*MockHandler) ResetWorkflowExecution

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

RespondCrossClusterTasksCompleted mocks base method.

func (*MockHandler) RespondDecisionTaskCompleted

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

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL