Documentation ¶
Overview ¶
Package history is a generated GoMock package.
Index ¶
- Constants
- Variables
- func NewEngineWithShardContext(shard shard.Context, visibilityMgr persistence.VisibilityManager, ...) engine.Engine
- func NewService(params *commonResource.Params) (resource.Resource, error)
- type GRPCHandler
- func (g GRPCHandler) CloseShard(ctx context.Context, request *historyv1.CloseShardRequest) (*historyv1.CloseShardResponse, error)
- func (g GRPCHandler) CountDLQMessages(ctx context.Context, request *historyv1.CountDLQMessagesRequest) (*historyv1.CountDLQMessagesResponse, error)
- func (g GRPCHandler) DescribeHistoryHost(ctx context.Context, request *historyv1.DescribeHistoryHostRequest) (*historyv1.DescribeHistoryHostResponse, error)
- func (g GRPCHandler) DescribeMutableState(ctx context.Context, request *historyv1.DescribeMutableStateRequest) (*historyv1.DescribeMutableStateResponse, error)
- func (g GRPCHandler) DescribeQueue(ctx context.Context, request *historyv1.DescribeQueueRequest) (*historyv1.DescribeQueueResponse, error)
- func (g GRPCHandler) DescribeWorkflowExecution(ctx context.Context, request *historyv1.DescribeWorkflowExecutionRequest) (*historyv1.DescribeWorkflowExecutionResponse, error)
- func (g GRPCHandler) GetCrossClusterTasks(ctx context.Context, request *historyv1.GetCrossClusterTasksRequest) (*historyv1.GetCrossClusterTasksResponse, error)
- func (g GRPCHandler) GetDLQReplicationMessages(ctx context.Context, request *historyv1.GetDLQReplicationMessagesRequest) (*historyv1.GetDLQReplicationMessagesResponse, error)
- func (g GRPCHandler) GetFailoverInfo(ctx context.Context, request *historyv1.GetFailoverInfoRequest) (*historyv1.GetFailoverInfoResponse, error)
- func (g GRPCHandler) GetMutableState(ctx context.Context, request *historyv1.GetMutableStateRequest) (*historyv1.GetMutableStateResponse, error)
- func (g GRPCHandler) GetReplicationMessages(ctx context.Context, request *historyv1.GetReplicationMessagesRequest) (*historyv1.GetReplicationMessagesResponse, error)
- func (g GRPCHandler) Health(ctx context.Context, _ *apiv1.HealthRequest) (*apiv1.HealthResponse, error)
- func (g GRPCHandler) MergeDLQMessages(ctx context.Context, request *historyv1.MergeDLQMessagesRequest) (*historyv1.MergeDLQMessagesResponse, error)
- func (g GRPCHandler) NotifyFailoverMarkers(ctx context.Context, request *historyv1.NotifyFailoverMarkersRequest) (*historyv1.NotifyFailoverMarkersResponse, error)
- func (g GRPCHandler) PollMutableState(ctx context.Context, request *historyv1.PollMutableStateRequest) (*historyv1.PollMutableStateResponse, error)
- func (g GRPCHandler) PurgeDLQMessages(ctx context.Context, request *historyv1.PurgeDLQMessagesRequest) (*historyv1.PurgeDLQMessagesResponse, error)
- func (g GRPCHandler) QueryWorkflow(ctx context.Context, request *historyv1.QueryWorkflowRequest) (*historyv1.QueryWorkflowResponse, error)
- func (g GRPCHandler) ReadDLQMessages(ctx context.Context, request *historyv1.ReadDLQMessagesRequest) (*historyv1.ReadDLQMessagesResponse, error)
- func (g GRPCHandler) ReapplyEvents(ctx context.Context, request *historyv1.ReapplyEventsRequest) (*historyv1.ReapplyEventsResponse, error)
- func (g GRPCHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *historyv1.RecordActivityTaskHeartbeatRequest) (*historyv1.RecordActivityTaskHeartbeatResponse, error)
- func (g GRPCHandler) RecordActivityTaskStarted(ctx context.Context, request *historyv1.RecordActivityTaskStartedRequest) (*historyv1.RecordActivityTaskStartedResponse, error)
- func (g GRPCHandler) RecordChildExecutionCompleted(ctx context.Context, request *historyv1.RecordChildExecutionCompletedRequest) (*historyv1.RecordChildExecutionCompletedResponse, error)
- func (g GRPCHandler) RecordDecisionTaskStarted(ctx context.Context, request *historyv1.RecordDecisionTaskStartedRequest) (*historyv1.RecordDecisionTaskStartedResponse, error)
- func (g GRPCHandler) RefreshWorkflowTasks(ctx context.Context, request *historyv1.RefreshWorkflowTasksRequest) (*historyv1.RefreshWorkflowTasksResponse, error)
- func (g GRPCHandler) Register(dispatcher *yarpc.Dispatcher)
- func (g GRPCHandler) RemoveSignalMutableState(ctx context.Context, request *historyv1.RemoveSignalMutableStateRequest) (*historyv1.RemoveSignalMutableStateResponse, error)
- func (g GRPCHandler) RemoveTask(ctx context.Context, request *historyv1.RemoveTaskRequest) (*historyv1.RemoveTaskResponse, error)
- func (g GRPCHandler) ReplicateEventsV2(ctx context.Context, request *historyv1.ReplicateEventsV2Request) (*historyv1.ReplicateEventsV2Response, error)
- func (g GRPCHandler) RequestCancelWorkflowExecution(ctx context.Context, request *historyv1.RequestCancelWorkflowExecutionRequest) (*historyv1.RequestCancelWorkflowExecutionResponse, error)
- func (g GRPCHandler) ResetQueue(ctx context.Context, request *historyv1.ResetQueueRequest) (*historyv1.ResetQueueResponse, error)
- func (g GRPCHandler) ResetStickyTaskList(ctx context.Context, request *historyv1.ResetStickyTaskListRequest) (*historyv1.ResetStickyTaskListResponse, error)
- func (g GRPCHandler) ResetWorkflowExecution(ctx context.Context, request *historyv1.ResetWorkflowExecutionRequest) (*historyv1.ResetWorkflowExecutionResponse, error)
- func (g GRPCHandler) RespondActivityTaskCanceled(ctx context.Context, request *historyv1.RespondActivityTaskCanceledRequest) (*historyv1.RespondActivityTaskCanceledResponse, error)
- func (g GRPCHandler) RespondActivityTaskCompleted(ctx context.Context, request *historyv1.RespondActivityTaskCompletedRequest) (*historyv1.RespondActivityTaskCompletedResponse, error)
- func (g GRPCHandler) RespondActivityTaskFailed(ctx context.Context, request *historyv1.RespondActivityTaskFailedRequest) (*historyv1.RespondActivityTaskFailedResponse, error)
- func (g GRPCHandler) RespondCrossClusterTasksCompleted(ctx context.Context, ...) (*historyv1.RespondCrossClusterTasksCompletedResponse, error)
- func (g GRPCHandler) RespondDecisionTaskCompleted(ctx context.Context, request *historyv1.RespondDecisionTaskCompletedRequest) (*historyv1.RespondDecisionTaskCompletedResponse, error)
- func (g GRPCHandler) RespondDecisionTaskFailed(ctx context.Context, request *historyv1.RespondDecisionTaskFailedRequest) (*historyv1.RespondDecisionTaskFailedResponse, error)
- func (g GRPCHandler) ScheduleDecisionTask(ctx context.Context, request *historyv1.ScheduleDecisionTaskRequest) (*historyv1.ScheduleDecisionTaskResponse, error)
- func (g GRPCHandler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*historyv1.SignalWithStartWorkflowExecutionResponse, error)
- func (g GRPCHandler) SignalWorkflowExecution(ctx context.Context, request *historyv1.SignalWorkflowExecutionRequest) (*historyv1.SignalWorkflowExecutionResponse, error)
- func (g GRPCHandler) StartWorkflowExecution(ctx context.Context, request *historyv1.StartWorkflowExecutionRequest) (*historyv1.StartWorkflowExecutionResponse, error)
- func (g GRPCHandler) SyncActivity(ctx context.Context, request *historyv1.SyncActivityRequest) (*historyv1.SyncActivityResponse, error)
- func (g GRPCHandler) SyncShardStatus(ctx context.Context, request *historyv1.SyncShardStatusRequest) (*historyv1.SyncShardStatusResponse, error)
- func (g GRPCHandler) TerminateWorkflowExecution(ctx context.Context, request *historyv1.TerminateWorkflowExecutionRequest) (*historyv1.TerminateWorkflowExecutionResponse, error)
- type Handler
- type MockHandler
- func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error
- func (m *MockHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.HistoryCountDLQMessagesResponse, error)
- func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
- func (m *MockHandler) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)
- func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
- func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
- func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
- func (m *MockHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
- func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
- func (m *MockHandler) GetFailoverInfo(arg0 context.Context, arg1 *types.GetFailoverInfoRequest) (*types.GetFailoverInfoResponse, error)
- func (m *MockHandler) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)
- func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
- func (m *MockHandler) Health(arg0 context.Context) (*types.HealthStatus, error)
- func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
- func (m *MockHandler) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest) error
- func (m *MockHandler) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)
- func (m *MockHandler) PrepareToStop(arg0 time.Duration) time.Duration
- func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error
- func (m *MockHandler) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)
- func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
- func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest) error
- func (m *MockHandler) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockHandler) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)
- func (m *MockHandler) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest) error
- func (m *MockHandler) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)
- func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest) error
- func (m *MockHandler) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest) error
- func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error
- func (m *MockHandler) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request) error
- func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest) error
- func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error
- func (m *MockHandler) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)
- func (m *MockHandler) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
- func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest) error
- func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest) error
- func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest) error
- func (m *MockHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
- func (m *MockHandler) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
- func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest) error
- func (m *MockHandler) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest) error
- func (m *MockHandler) SignalWithStartWorkflowExecution(arg0 context.Context, ...) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest) error
- func (m *MockHandler) Start()
- func (m *MockHandler) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockHandler) Stop()
- func (m *MockHandler) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest) error
- func (m *MockHandler) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest) error
- func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest) error
- type MockHandlerMockRecorder
- func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) CountDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetFailoverInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Health(arg0 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PollMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PrepareToStop(arg0 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Start() *gomock.Call
- func (mr *MockHandlerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Stop() *gomock.Call
- func (mr *MockHandlerMockRecorder) SyncActivity(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) SyncShardStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- type Service
- type ThriftHandler
- func (g ThriftHandler) CloseShard(ctx context.Context, Request *shared.CloseShardRequest) (err error)
- func (g ThriftHandler) DescribeHistoryHost(ctx context.Context, Request *shared.DescribeHistoryHostRequest) (dp1 *shared.DescribeHistoryHostResponse, err error)
- func (g ThriftHandler) DescribeMutableState(ctx context.Context, Request *history.DescribeMutableStateRequest) (dp1 *history.DescribeMutableStateResponse, err error)
- func (g ThriftHandler) DescribeQueue(ctx context.Context, Request *shared.DescribeQueueRequest) (dp1 *shared.DescribeQueueResponse, err error)
- func (g ThriftHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *history.DescribeWorkflowExecutionRequest) (dp1 *shared.DescribeWorkflowExecutionResponse, err error)
- func (g ThriftHandler) GetCrossClusterTasks(ctx context.Context, Request *shared.GetCrossClusterTasksRequest) (gp1 *shared.GetCrossClusterTasksResponse, err error)
- func (g ThriftHandler) GetDLQReplicationMessages(ctx context.Context, Request *replicator.GetDLQReplicationMessagesRequest) (gp1 *replicator.GetDLQReplicationMessagesResponse, err error)
- func (g ThriftHandler) GetFailoverInfo(ctx context.Context, Request *history.GetFailoverInfoRequest) (gp1 *history.GetFailoverInfoResponse, err error)
- func (g ThriftHandler) GetMutableState(ctx context.Context, GetRequest *history.GetMutableStateRequest) (gp1 *history.GetMutableStateResponse, err error)
- func (g ThriftHandler) GetReplicationMessages(ctx context.Context, Request *replicator.GetReplicationMessagesRequest) (gp1 *replicator.GetReplicationMessagesResponse, err error)
- func (t ThriftHandler) Health(ctx context.Context) (*health.HealthStatus, error)
- func (g ThriftHandler) MergeDLQMessages(ctx context.Context, Request *replicator.MergeDLQMessagesRequest) (mp1 *replicator.MergeDLQMessagesResponse, err error)
- func (g ThriftHandler) NotifyFailoverMarkers(ctx context.Context, Request *history.NotifyFailoverMarkersRequest) (err error)
- func (g ThriftHandler) PollMutableState(ctx context.Context, PollRequest *history.PollMutableStateRequest) (pp1 *history.PollMutableStateResponse, err error)
- func (g ThriftHandler) PurgeDLQMessages(ctx context.Context, Request *replicator.PurgeDLQMessagesRequest) (err error)
- func (g ThriftHandler) QueryWorkflow(ctx context.Context, QueryRequest *history.QueryWorkflowRequest) (qp1 *history.QueryWorkflowResponse, err error)
- func (g ThriftHandler) ReadDLQMessages(ctx context.Context, Request *replicator.ReadDLQMessagesRequest) (rp1 *replicator.ReadDLQMessagesResponse, err error)
- func (g ThriftHandler) ReapplyEvents(ctx context.Context, ReapplyEventsRequest *history.ReapplyEventsRequest) (err error)
- func (g ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, ...) (rp1 *shared.RecordActivityTaskHeartbeatResponse, err error)
- func (g ThriftHandler) RecordActivityTaskStarted(ctx context.Context, AddRequest *history.RecordActivityTaskStartedRequest) (rp1 *history.RecordActivityTaskStartedResponse, err error)
- func (g ThriftHandler) RecordChildExecutionCompleted(ctx context.Context, ...) (err error)
- func (g ThriftHandler) RecordDecisionTaskStarted(ctx context.Context, AddRequest *history.RecordDecisionTaskStartedRequest) (rp1 *history.RecordDecisionTaskStartedResponse, err error)
- func (g ThriftHandler) RefreshWorkflowTasks(ctx context.Context, Request *history.RefreshWorkflowTasksRequest) (err error)
- func (t ThriftHandler) Register(dispatcher *yarpc.Dispatcher)
- func (g ThriftHandler) RemoveSignalMutableState(ctx context.Context, RemoveRequest *history.RemoveSignalMutableStateRequest) (err error)
- func (g ThriftHandler) RemoveTask(ctx context.Context, Request *shared.RemoveTaskRequest) (err error)
- func (g ThriftHandler) ReplicateEventsV2(ctx context.Context, ReplicateV2Request *history.ReplicateEventsV2Request) (err error)
- func (g ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, ...) (err error)
- func (g ThriftHandler) ResetQueue(ctx context.Context, Request *shared.ResetQueueRequest) (err error)
- func (g ThriftHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *history.ResetStickyTaskListRequest) (rp1 *history.ResetStickyTaskListResponse, err error)
- func (g ThriftHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *history.ResetWorkflowExecutionRequest) (rp1 *shared.ResetWorkflowExecutionResponse, err error)
- func (g ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, ...) (err error)
- func (g ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, ...) (err error)
- func (g ThriftHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *history.RespondActivityTaskFailedRequest) (err error)
- func (g ThriftHandler) RespondCrossClusterTasksCompleted(ctx context.Context, Request *shared.RespondCrossClusterTasksCompletedRequest) (rp1 *shared.RespondCrossClusterTasksCompletedResponse, err error)
- func (g ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, ...) (rp1 *history.RespondDecisionTaskCompletedResponse, err error)
- func (g ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *history.RespondDecisionTaskFailedRequest) (err error)
- func (g ThriftHandler) ScheduleDecisionTask(ctx context.Context, ScheduleRequest *history.ScheduleDecisionTaskRequest) (err error)
- func (g ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (sp1 *shared.StartWorkflowExecutionResponse, err error)
- func (g ThriftHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *history.SignalWorkflowExecutionRequest) (err error)
- func (g ThriftHandler) StartWorkflowExecution(ctx context.Context, StartRequest *history.StartWorkflowExecutionRequest) (sp1 *shared.StartWorkflowExecutionResponse, err error)
- func (g ThriftHandler) SyncActivity(ctx context.Context, SyncActivityRequest *history.SyncActivityRequest) (err error)
- func (g ThriftHandler) SyncShardStatus(ctx context.Context, SyncShardStatusRequest *history.SyncShardStatusRequest) (err error)
- func (g ThriftHandler) TerminateWorkflowExecution(ctx context.Context, ...) (err error)
Constants ¶
const ( // TerminateIfRunningReason reason for terminateIfRunning TerminateIfRunningReason = "TerminateIfRunning Policy" // TerminateIfRunningDetailsTemplate details template for terminateIfRunning TerminateIfRunningDetailsTemplate = "New runID: %s" )
Variables ¶
var ( // FailedWorkflowCloseState is a set of failed workflow close states, used for start workflow policy // for start workflow execution API FailedWorkflowCloseState = map[int]bool{ persistence.WorkflowCloseStatusFailed: true, persistence.WorkflowCloseStatusCanceled: true, persistence.WorkflowCloseStatusTerminated: true, persistence.WorkflowCloseStatusTimedOut: true, } )
Functions ¶
func NewEngineWithShardContext ¶
func NewEngineWithShardContext( shard shard.Context, visibilityMgr persistence.VisibilityManager, matching matching.Client, publicClient workflowserviceclient.Interface, historyEventNotifier events.Notifier, config *config.Config, crossClusterTaskFetchers task.Fetchers, replicationTaskFetchers replication.TaskFetchers, rawMatchingClient matching.Client, queueTaskProcessor task.Processor, failoverCoordinator failover.Coordinator, wfIDCache workflowcache.WFCache, ) engine.Engine
NewEngineWithShardContext creates an instance of history engine
func NewService ¶
func NewService( params *commonResource.Params, ) (resource.Resource, error)
NewService builds a new cadence-history service
Types ¶
type GRPCHandler ¶ added in v1.2.7
type GRPCHandler struct {
// contains filtered or unexported fields
}
func NewGRPCHandler ¶ added in v1.2.7
func NewGRPCHandler(h Handler) GRPCHandler
func (GRPCHandler) CloseShard ¶ added in v1.2.7
func (g GRPCHandler) CloseShard(ctx context.Context, request *historyv1.CloseShardRequest) (*historyv1.CloseShardResponse, error)
func (GRPCHandler) CountDLQMessages ¶ added in v1.2.7
func (g GRPCHandler) CountDLQMessages(ctx context.Context, request *historyv1.CountDLQMessagesRequest) (*historyv1.CountDLQMessagesResponse, error)
func (GRPCHandler) DescribeHistoryHost ¶ added in v1.2.7
func (g GRPCHandler) DescribeHistoryHost(ctx context.Context, request *historyv1.DescribeHistoryHostRequest) (*historyv1.DescribeHistoryHostResponse, error)
func (GRPCHandler) DescribeMutableState ¶ added in v1.2.7
func (g GRPCHandler) DescribeMutableState(ctx context.Context, request *historyv1.DescribeMutableStateRequest) (*historyv1.DescribeMutableStateResponse, error)
func (GRPCHandler) DescribeQueue ¶ added in v1.2.7
func (g GRPCHandler) DescribeQueue(ctx context.Context, request *historyv1.DescribeQueueRequest) (*historyv1.DescribeQueueResponse, error)
func (GRPCHandler) DescribeWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) DescribeWorkflowExecution(ctx context.Context, request *historyv1.DescribeWorkflowExecutionRequest) (*historyv1.DescribeWorkflowExecutionResponse, error)
func (GRPCHandler) GetCrossClusterTasks ¶ added in v1.2.7
func (g GRPCHandler) GetCrossClusterTasks(ctx context.Context, request *historyv1.GetCrossClusterTasksRequest) (*historyv1.GetCrossClusterTasksResponse, error)
func (GRPCHandler) GetDLQReplicationMessages ¶ added in v1.2.7
func (g GRPCHandler) GetDLQReplicationMessages(ctx context.Context, request *historyv1.GetDLQReplicationMessagesRequest) (*historyv1.GetDLQReplicationMessagesResponse, error)
func (GRPCHandler) GetFailoverInfo ¶ added in v1.2.7
func (g GRPCHandler) GetFailoverInfo(ctx context.Context, request *historyv1.GetFailoverInfoRequest) (*historyv1.GetFailoverInfoResponse, error)
func (GRPCHandler) GetMutableState ¶ added in v1.2.7
func (g GRPCHandler) GetMutableState(ctx context.Context, request *historyv1.GetMutableStateRequest) (*historyv1.GetMutableStateResponse, error)
func (GRPCHandler) GetReplicationMessages ¶ added in v1.2.7
func (g GRPCHandler) GetReplicationMessages(ctx context.Context, request *historyv1.GetReplicationMessagesRequest) (*historyv1.GetReplicationMessagesResponse, error)
func (GRPCHandler) Health ¶ added in v1.2.7
func (g GRPCHandler) Health(ctx context.Context, _ *apiv1.HealthRequest) (*apiv1.HealthResponse, error)
func (GRPCHandler) MergeDLQMessages ¶ added in v1.2.7
func (g GRPCHandler) MergeDLQMessages(ctx context.Context, request *historyv1.MergeDLQMessagesRequest) (*historyv1.MergeDLQMessagesResponse, error)
func (GRPCHandler) NotifyFailoverMarkers ¶ added in v1.2.7
func (g GRPCHandler) NotifyFailoverMarkers(ctx context.Context, request *historyv1.NotifyFailoverMarkersRequest) (*historyv1.NotifyFailoverMarkersResponse, error)
func (GRPCHandler) PollMutableState ¶ added in v1.2.7
func (g GRPCHandler) PollMutableState(ctx context.Context, request *historyv1.PollMutableStateRequest) (*historyv1.PollMutableStateResponse, error)
func (GRPCHandler) PurgeDLQMessages ¶ added in v1.2.7
func (g GRPCHandler) PurgeDLQMessages(ctx context.Context, request *historyv1.PurgeDLQMessagesRequest) (*historyv1.PurgeDLQMessagesResponse, error)
func (GRPCHandler) QueryWorkflow ¶ added in v1.2.7
func (g GRPCHandler) QueryWorkflow(ctx context.Context, request *historyv1.QueryWorkflowRequest) (*historyv1.QueryWorkflowResponse, error)
func (GRPCHandler) ReadDLQMessages ¶ added in v1.2.7
func (g GRPCHandler) ReadDLQMessages(ctx context.Context, request *historyv1.ReadDLQMessagesRequest) (*historyv1.ReadDLQMessagesResponse, error)
func (GRPCHandler) ReapplyEvents ¶ added in v1.2.7
func (g GRPCHandler) ReapplyEvents(ctx context.Context, request *historyv1.ReapplyEventsRequest) (*historyv1.ReapplyEventsResponse, error)
func (GRPCHandler) RecordActivityTaskHeartbeat ¶ added in v1.2.7
func (g GRPCHandler) RecordActivityTaskHeartbeat(ctx context.Context, request *historyv1.RecordActivityTaskHeartbeatRequest) (*historyv1.RecordActivityTaskHeartbeatResponse, error)
func (GRPCHandler) RecordActivityTaskStarted ¶ added in v1.2.7
func (g GRPCHandler) RecordActivityTaskStarted(ctx context.Context, request *historyv1.RecordActivityTaskStartedRequest) (*historyv1.RecordActivityTaskStartedResponse, error)
func (GRPCHandler) RecordChildExecutionCompleted ¶ added in v1.2.7
func (g GRPCHandler) RecordChildExecutionCompleted(ctx context.Context, request *historyv1.RecordChildExecutionCompletedRequest) (*historyv1.RecordChildExecutionCompletedResponse, error)
func (GRPCHandler) RecordDecisionTaskStarted ¶ added in v1.2.7
func (g GRPCHandler) RecordDecisionTaskStarted(ctx context.Context, request *historyv1.RecordDecisionTaskStartedRequest) (*historyv1.RecordDecisionTaskStartedResponse, error)
func (GRPCHandler) RefreshWorkflowTasks ¶ added in v1.2.7
func (g GRPCHandler) RefreshWorkflowTasks(ctx context.Context, request *historyv1.RefreshWorkflowTasksRequest) (*historyv1.RefreshWorkflowTasksResponse, error)
func (GRPCHandler) Register ¶ added in v1.2.7
func (g GRPCHandler) Register(dispatcher *yarpc.Dispatcher)
func (GRPCHandler) RemoveSignalMutableState ¶ added in v1.2.7
func (g GRPCHandler) RemoveSignalMutableState(ctx context.Context, request *historyv1.RemoveSignalMutableStateRequest) (*historyv1.RemoveSignalMutableStateResponse, error)
func (GRPCHandler) RemoveTask ¶ added in v1.2.7
func (g GRPCHandler) RemoveTask(ctx context.Context, request *historyv1.RemoveTaskRequest) (*historyv1.RemoveTaskResponse, error)
func (GRPCHandler) ReplicateEventsV2 ¶ added in v1.2.7
func (g GRPCHandler) ReplicateEventsV2(ctx context.Context, request *historyv1.ReplicateEventsV2Request) (*historyv1.ReplicateEventsV2Response, error)
func (GRPCHandler) RequestCancelWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) RequestCancelWorkflowExecution(ctx context.Context, request *historyv1.RequestCancelWorkflowExecutionRequest) (*historyv1.RequestCancelWorkflowExecutionResponse, error)
func (GRPCHandler) ResetQueue ¶ added in v1.2.7
func (g GRPCHandler) ResetQueue(ctx context.Context, request *historyv1.ResetQueueRequest) (*historyv1.ResetQueueResponse, error)
func (GRPCHandler) ResetStickyTaskList ¶ added in v1.2.7
func (g GRPCHandler) ResetStickyTaskList(ctx context.Context, request *historyv1.ResetStickyTaskListRequest) (*historyv1.ResetStickyTaskListResponse, error)
func (GRPCHandler) ResetWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) ResetWorkflowExecution(ctx context.Context, request *historyv1.ResetWorkflowExecutionRequest) (*historyv1.ResetWorkflowExecutionResponse, error)
func (GRPCHandler) RespondActivityTaskCanceled ¶ added in v1.2.7
func (g GRPCHandler) RespondActivityTaskCanceled(ctx context.Context, request *historyv1.RespondActivityTaskCanceledRequest) (*historyv1.RespondActivityTaskCanceledResponse, error)
func (GRPCHandler) RespondActivityTaskCompleted ¶ added in v1.2.7
func (g GRPCHandler) RespondActivityTaskCompleted(ctx context.Context, request *historyv1.RespondActivityTaskCompletedRequest) (*historyv1.RespondActivityTaskCompletedResponse, error)
func (GRPCHandler) RespondActivityTaskFailed ¶ added in v1.2.7
func (g GRPCHandler) RespondActivityTaskFailed(ctx context.Context, request *historyv1.RespondActivityTaskFailedRequest) (*historyv1.RespondActivityTaskFailedResponse, error)
func (GRPCHandler) RespondCrossClusterTasksCompleted ¶ added in v1.2.7
func (g GRPCHandler) RespondCrossClusterTasksCompleted(ctx context.Context, request *historyv1.RespondCrossClusterTasksCompletedRequest) (*historyv1.RespondCrossClusterTasksCompletedResponse, error)
func (GRPCHandler) RespondDecisionTaskCompleted ¶ added in v1.2.7
func (g GRPCHandler) RespondDecisionTaskCompleted(ctx context.Context, request *historyv1.RespondDecisionTaskCompletedRequest) (*historyv1.RespondDecisionTaskCompletedResponse, error)
func (GRPCHandler) RespondDecisionTaskFailed ¶ added in v1.2.7
func (g GRPCHandler) RespondDecisionTaskFailed(ctx context.Context, request *historyv1.RespondDecisionTaskFailedRequest) (*historyv1.RespondDecisionTaskFailedResponse, error)
func (GRPCHandler) ScheduleDecisionTask ¶ added in v1.2.7
func (g GRPCHandler) ScheduleDecisionTask(ctx context.Context, request *historyv1.ScheduleDecisionTaskRequest) (*historyv1.ScheduleDecisionTaskResponse, error)
func (GRPCHandler) SignalWithStartWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) SignalWithStartWorkflowExecution(ctx context.Context, request *historyv1.SignalWithStartWorkflowExecutionRequest) (*historyv1.SignalWithStartWorkflowExecutionResponse, error)
func (GRPCHandler) SignalWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) SignalWorkflowExecution(ctx context.Context, request *historyv1.SignalWorkflowExecutionRequest) (*historyv1.SignalWorkflowExecutionResponse, error)
func (GRPCHandler) StartWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) StartWorkflowExecution(ctx context.Context, request *historyv1.StartWorkflowExecutionRequest) (*historyv1.StartWorkflowExecutionResponse, error)
func (GRPCHandler) SyncActivity ¶ added in v1.2.7
func (g GRPCHandler) SyncActivity(ctx context.Context, request *historyv1.SyncActivityRequest) (*historyv1.SyncActivityResponse, error)
func (GRPCHandler) SyncShardStatus ¶ added in v1.2.7
func (g GRPCHandler) SyncShardStatus(ctx context.Context, request *historyv1.SyncShardStatusRequest) (*historyv1.SyncShardStatusResponse, error)
func (GRPCHandler) TerminateWorkflowExecution ¶ added in v1.2.7
func (g GRPCHandler) TerminateWorkflowExecution(ctx context.Context, request *historyv1.TerminateWorkflowExecutionRequest) (*historyv1.TerminateWorkflowExecutionResponse, error)
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) }
Handler interface for history service
type MockHandler ¶ added in v0.17.0
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface.
func NewMockHandler ¶ added in v0.17.0
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance.
func (*MockHandler) CloseShard ¶ added in v0.17.0
func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error
CloseShard mocks base method.
func (*MockHandler) CountDLQMessages ¶ added in v0.25.0
func (m *MockHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.HistoryCountDLQMessagesResponse, error)
CountDLQMessages mocks base method.
func (*MockHandler) DescribeHistoryHost ¶ added in v0.17.0
func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method.
func (*MockHandler) DescribeMutableState ¶ added in v0.17.0
func (m *MockHandler) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest) (*types.DescribeMutableStateResponse, error)
DescribeMutableState mocks base method.
func (*MockHandler) DescribeQueue ¶ added in v0.17.0
func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
DescribeQueue mocks base method.
func (*MockHandler) DescribeWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest) (*types.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockHandler) EXPECT ¶ added in v0.17.0
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHandler) GetCrossClusterTasks ¶ added in v0.23.1
func (m *MockHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
GetCrossClusterTasks mocks base method.
func (*MockHandler) GetDLQReplicationMessages ¶ added in v0.17.0
func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method.
func (*MockHandler) GetFailoverInfo ¶ added in v0.24.0
func (m *MockHandler) GetFailoverInfo(arg0 context.Context, arg1 *types.GetFailoverInfoRequest) (*types.GetFailoverInfoResponse, error)
GetFailoverInfo mocks base method.
func (*MockHandler) GetMutableState ¶ added in v0.17.0
func (m *MockHandler) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest) (*types.GetMutableStateResponse, error)
GetMutableState mocks base method.
func (*MockHandler) GetReplicationMessages ¶ added in v0.17.0
func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method.
func (*MockHandler) Health ¶ added in v0.17.0
func (m *MockHandler) Health(arg0 context.Context) (*types.HealthStatus, error)
Health mocks base method.
func (*MockHandler) MergeDLQMessages ¶ added in v0.17.0
func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method.
func (*MockHandler) NotifyFailoverMarkers ¶ added in v0.17.0
func (m *MockHandler) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest) error
NotifyFailoverMarkers mocks base method.
func (*MockHandler) PollMutableState ¶ added in v0.17.0
func (m *MockHandler) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest) (*types.PollMutableStateResponse, error)
PollMutableState mocks base method.
func (*MockHandler) PrepareToStop ¶ added in v0.23.1
func (m *MockHandler) PrepareToStop(arg0 time.Duration) time.Duration
PrepareToStop mocks base method.
func (*MockHandler) PurgeDLQMessages ¶ added in v0.17.0
func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error
PurgeDLQMessages mocks base method.
func (*MockHandler) QueryWorkflow ¶ added in v0.17.0
func (m *MockHandler) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest) (*types.HistoryQueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockHandler) ReadDLQMessages ¶ added in v0.17.0
func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
ReadDLQMessages mocks base method.
func (*MockHandler) ReapplyEvents ¶ added in v0.17.0
func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest) error
ReapplyEvents mocks base method.
func (*MockHandler) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (m *MockHandler) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest) (*types.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method.
func (*MockHandler) RecordActivityTaskStarted ¶ added in v0.17.0
func (m *MockHandler) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest) (*types.RecordActivityTaskStartedResponse, error)
RecordActivityTaskStarted mocks base method.
func (*MockHandler) RecordChildExecutionCompleted ¶ added in v0.17.0
func (m *MockHandler) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest) error
RecordChildExecutionCompleted mocks base method.
func (*MockHandler) RecordDecisionTaskStarted ¶ added in v0.17.0
func (m *MockHandler) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest) (*types.RecordDecisionTaskStartedResponse, error)
RecordDecisionTaskStarted mocks base method.
func (*MockHandler) RefreshWorkflowTasks ¶ added in v0.17.0
func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest) error
RefreshWorkflowTasks mocks base method.
func (*MockHandler) RemoveSignalMutableState ¶ added in v0.17.0
func (m *MockHandler) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest) error
RemoveSignalMutableState mocks base method.
func (*MockHandler) RemoveTask ¶ added in v0.17.0
func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error
RemoveTask mocks base method.
func (*MockHandler) ReplicateEventsV2 ¶ added in v0.17.0
func (m *MockHandler) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request) error
ReplicateEventsV2 mocks base method.
func (*MockHandler) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest) error
RequestCancelWorkflowExecution mocks base method.
func (*MockHandler) ResetQueue ¶ added in v0.17.0
func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error
ResetQueue mocks base method.
func (*MockHandler) ResetStickyTaskList ¶ added in v0.17.0
func (m *MockHandler) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest) (*types.HistoryResetStickyTaskListResponse, error)
ResetStickyTaskList mocks base method.
func (*MockHandler) ResetWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest) (*types.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockHandler) RespondActivityTaskCanceled ¶ added in v0.17.0
func (m *MockHandler) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest) error
RespondActivityTaskCanceled mocks base method.
func (*MockHandler) RespondActivityTaskCompleted ¶ added in v0.17.0
func (m *MockHandler) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest) error
RespondActivityTaskCompleted mocks base method.
func (*MockHandler) RespondActivityTaskFailed ¶ added in v0.17.0
func (m *MockHandler) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest) error
RespondActivityTaskFailed mocks base method.
func (*MockHandler) RespondCrossClusterTasksCompleted ¶ added in v0.23.1
func (m *MockHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
RespondCrossClusterTasksCompleted mocks base method.
func (*MockHandler) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (m *MockHandler) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
RespondDecisionTaskCompleted mocks base method.
func (*MockHandler) RespondDecisionTaskFailed ¶ added in v0.17.0
func (m *MockHandler) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest) error
RespondDecisionTaskFailed mocks base method.
func (*MockHandler) ScheduleDecisionTask ¶ added in v0.17.0
func (m *MockHandler) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest) error
ScheduleDecisionTask mocks base method.
func (*MockHandler) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWithStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method.
func (*MockHandler) SignalWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest) error
SignalWorkflowExecution mocks base method.
func (*MockHandler) StartWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest) (*types.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method.
func (*MockHandler) SyncActivity ¶ added in v0.17.0
func (m *MockHandler) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest) error
SyncActivity mocks base method.
func (*MockHandler) SyncShardStatus ¶ added in v0.17.0
func (m *MockHandler) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest) error
SyncShardStatus mocks base method.
func (*MockHandler) TerminateWorkflowExecution ¶ added in v0.17.0
func (m *MockHandler) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest) error
TerminateWorkflowExecution mocks base method.
type MockHandlerMockRecorder ¶ added in v0.17.0
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler.
func (*MockHandlerMockRecorder) CloseShard ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard.
func (*MockHandlerMockRecorder) CountDLQMessages ¶ added in v0.25.0
func (mr *MockHandlerMockRecorder) CountDLQMessages(arg0, arg1 interface{}) *gomock.Call
CountDLQMessages indicates an expected call of CountDLQMessages.
func (*MockHandlerMockRecorder) DescribeHistoryHost ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost.
func (*MockHandlerMockRecorder) DescribeMutableState ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) DescribeMutableState(arg0, arg1 interface{}) *gomock.Call
DescribeMutableState indicates an expected call of DescribeMutableState.
func (*MockHandlerMockRecorder) DescribeQueue ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
DescribeQueue indicates an expected call of DescribeQueue.
func (*MockHandlerMockRecorder) DescribeWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockHandlerMockRecorder) GetCrossClusterTasks ¶ added in v0.23.1
func (mr *MockHandlerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.
func (*MockHandlerMockRecorder) GetDLQReplicationMessages ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockHandlerMockRecorder) GetFailoverInfo ¶ added in v0.24.0
func (mr *MockHandlerMockRecorder) GetFailoverInfo(arg0, arg1 interface{}) *gomock.Call
GetFailoverInfo indicates an expected call of GetFailoverInfo.
func (*MockHandlerMockRecorder) GetMutableState ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) GetMutableState(arg0, arg1 interface{}) *gomock.Call
GetMutableState indicates an expected call of GetMutableState.
func (*MockHandlerMockRecorder) GetReplicationMessages ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockHandlerMockRecorder) Health ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) Health(arg0 interface{}) *gomock.Call
Health indicates an expected call of Health.
func (*MockHandlerMockRecorder) MergeDLQMessages ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockHandlerMockRecorder) NotifyFailoverMarkers ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}) *gomock.Call
NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers.
func (*MockHandlerMockRecorder) PollMutableState ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) PollMutableState(arg0, arg1 interface{}) *gomock.Call
PollMutableState indicates an expected call of PollMutableState.
func (*MockHandlerMockRecorder) PrepareToStop ¶ added in v0.23.1
func (mr *MockHandlerMockRecorder) PrepareToStop(arg0 interface{}) *gomock.Call
PrepareToStop indicates an expected call of PrepareToStop.
func (*MockHandlerMockRecorder) PurgeDLQMessages ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockHandlerMockRecorder) QueryWorkflow ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockHandlerMockRecorder) ReadDLQMessages ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
ReadDLQMessages indicates an expected call of ReadDLQMessages.
func (*MockHandlerMockRecorder) ReapplyEvents ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockHandlerMockRecorder) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (*MockHandlerMockRecorder) RecordActivityTaskStarted ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}) *gomock.Call
RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.
func (*MockHandlerMockRecorder) RecordChildExecutionCompleted ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}) *gomock.Call
RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.
func (*MockHandlerMockRecorder) RecordDecisionTaskStarted ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}) *gomock.Call
RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted.
func (*MockHandlerMockRecorder) RefreshWorkflowTasks ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockHandlerMockRecorder) RemoveSignalMutableState ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}) *gomock.Call
RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.
func (*MockHandlerMockRecorder) RemoveTask ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask.
func (*MockHandlerMockRecorder) ReplicateEventsV2 ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}) *gomock.Call
ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.
func (*MockHandlerMockRecorder) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (*MockHandlerMockRecorder) ResetQueue ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
ResetQueue indicates an expected call of ResetQueue.
func (*MockHandlerMockRecorder) ResetStickyTaskList ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}) *gomock.Call
ResetStickyTaskList indicates an expected call of ResetStickyTaskList.
func (*MockHandlerMockRecorder) ResetWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockHandlerMockRecorder) RespondActivityTaskCanceled ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (*MockHandlerMockRecorder) RespondActivityTaskCompleted ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (*MockHandlerMockRecorder) RespondActivityTaskFailed ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (*MockHandlerMockRecorder) RespondCrossClusterTasksCompleted ¶ added in v0.23.1
func (mr *MockHandlerMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}) *gomock.Call
RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.
func (*MockHandlerMockRecorder) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted.
func (*MockHandlerMockRecorder) RespondDecisionTaskFailed ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}) *gomock.Call
RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed.
func (*MockHandlerMockRecorder) ScheduleDecisionTask ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}) *gomock.Call
ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask.
func (*MockHandlerMockRecorder) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (*MockHandlerMockRecorder) SignalWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.
func (*MockHandlerMockRecorder) Start ¶ added in v0.23.1
func (mr *MockHandlerMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockHandlerMockRecorder) StartWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (*MockHandlerMockRecorder) Stop ¶ added in v0.23.1
func (mr *MockHandlerMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockHandlerMockRecorder) SyncActivity ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) SyncActivity(arg0, arg1 interface{}) *gomock.Call
SyncActivity indicates an expected call of SyncActivity.
func (*MockHandlerMockRecorder) SyncShardStatus ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) SyncShardStatus(arg0, arg1 interface{}) *gomock.Call
SyncShardStatus indicates an expected call of SyncShardStatus.
func (*MockHandlerMockRecorder) TerminateWorkflowExecution ¶ added in v0.17.0
func (mr *MockHandlerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
type ThriftHandler ¶ added in v0.17.0
type ThriftHandler struct {
// contains filtered or unexported fields
}
func NewThriftHandler ¶ added in v0.17.0
func NewThriftHandler(h Handler) ThriftHandler
func (ThriftHandler) CloseShard ¶ added in v0.17.0
func (g ThriftHandler) CloseShard(ctx context.Context, Request *shared.CloseShardRequest) (err error)
func (ThriftHandler) DescribeHistoryHost ¶ added in v0.17.0
func (g ThriftHandler) DescribeHistoryHost(ctx context.Context, Request *shared.DescribeHistoryHostRequest) (dp1 *shared.DescribeHistoryHostResponse, err error)
func (ThriftHandler) DescribeMutableState ¶ added in v0.17.0
func (g ThriftHandler) DescribeMutableState(ctx context.Context, Request *history.DescribeMutableStateRequest) (dp1 *history.DescribeMutableStateResponse, err error)
func (ThriftHandler) DescribeQueue ¶ added in v0.17.0
func (g ThriftHandler) DescribeQueue(ctx context.Context, Request *shared.DescribeQueueRequest) (dp1 *shared.DescribeQueueResponse, err error)
func (ThriftHandler) DescribeWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) DescribeWorkflowExecution(ctx context.Context, DescribeRequest *history.DescribeWorkflowExecutionRequest) (dp1 *shared.DescribeWorkflowExecutionResponse, err error)
func (ThriftHandler) GetCrossClusterTasks ¶ added in v0.22.0
func (g ThriftHandler) GetCrossClusterTasks(ctx context.Context, Request *shared.GetCrossClusterTasksRequest) (gp1 *shared.GetCrossClusterTasksResponse, err error)
func (ThriftHandler) GetDLQReplicationMessages ¶ added in v0.17.0
func (g ThriftHandler) GetDLQReplicationMessages(ctx context.Context, Request *replicator.GetDLQReplicationMessagesRequest) (gp1 *replicator.GetDLQReplicationMessagesResponse, err error)
func (ThriftHandler) GetFailoverInfo ¶ added in v0.24.0
func (g ThriftHandler) GetFailoverInfo(ctx context.Context, Request *history.GetFailoverInfoRequest) (gp1 *history.GetFailoverInfoResponse, err error)
func (ThriftHandler) GetMutableState ¶ added in v0.17.0
func (g ThriftHandler) GetMutableState(ctx context.Context, GetRequest *history.GetMutableStateRequest) (gp1 *history.GetMutableStateResponse, err error)
func (ThriftHandler) GetReplicationMessages ¶ added in v0.17.0
func (g ThriftHandler) GetReplicationMessages(ctx context.Context, Request *replicator.GetReplicationMessagesRequest) (gp1 *replicator.GetReplicationMessagesResponse, err error)
func (ThriftHandler) Health ¶ added in v0.17.0
func (t ThriftHandler) Health(ctx context.Context) (*health.HealthStatus, error)
func (ThriftHandler) MergeDLQMessages ¶ added in v0.17.0
func (g ThriftHandler) MergeDLQMessages(ctx context.Context, Request *replicator.MergeDLQMessagesRequest) (mp1 *replicator.MergeDLQMessagesResponse, err error)
func (ThriftHandler) NotifyFailoverMarkers ¶ added in v0.17.0
func (g ThriftHandler) NotifyFailoverMarkers(ctx context.Context, Request *history.NotifyFailoverMarkersRequest) (err error)
func (ThriftHandler) PollMutableState ¶ added in v0.17.0
func (g ThriftHandler) PollMutableState(ctx context.Context, PollRequest *history.PollMutableStateRequest) (pp1 *history.PollMutableStateResponse, err error)
func (ThriftHandler) PurgeDLQMessages ¶ added in v0.17.0
func (g ThriftHandler) PurgeDLQMessages(ctx context.Context, Request *replicator.PurgeDLQMessagesRequest) (err error)
func (ThriftHandler) QueryWorkflow ¶ added in v0.17.0
func (g ThriftHandler) QueryWorkflow(ctx context.Context, QueryRequest *history.QueryWorkflowRequest) (qp1 *history.QueryWorkflowResponse, err error)
func (ThriftHandler) ReadDLQMessages ¶ added in v0.17.0
func (g ThriftHandler) ReadDLQMessages(ctx context.Context, Request *replicator.ReadDLQMessagesRequest) (rp1 *replicator.ReadDLQMessagesResponse, err error)
func (ThriftHandler) ReapplyEvents ¶ added in v0.17.0
func (g ThriftHandler) ReapplyEvents(ctx context.Context, ReapplyEventsRequest *history.ReapplyEventsRequest) (err error)
func (ThriftHandler) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (g ThriftHandler) RecordActivityTaskHeartbeat(ctx context.Context, HeartbeatRequest *history.RecordActivityTaskHeartbeatRequest) (rp1 *shared.RecordActivityTaskHeartbeatResponse, err error)
func (ThriftHandler) RecordActivityTaskStarted ¶ added in v0.17.0
func (g ThriftHandler) RecordActivityTaskStarted(ctx context.Context, AddRequest *history.RecordActivityTaskStartedRequest) (rp1 *history.RecordActivityTaskStartedResponse, err error)
func (ThriftHandler) RecordChildExecutionCompleted ¶ added in v0.17.0
func (g ThriftHandler) RecordChildExecutionCompleted(ctx context.Context, CompletionRequest *history.RecordChildExecutionCompletedRequest) (err error)
func (ThriftHandler) RecordDecisionTaskStarted ¶ added in v0.17.0
func (g ThriftHandler) RecordDecisionTaskStarted(ctx context.Context, AddRequest *history.RecordDecisionTaskStartedRequest) (rp1 *history.RecordDecisionTaskStartedResponse, err error)
func (ThriftHandler) RefreshWorkflowTasks ¶ added in v0.17.0
func (g ThriftHandler) RefreshWorkflowTasks(ctx context.Context, Request *history.RefreshWorkflowTasksRequest) (err error)
func (ThriftHandler) Register ¶ added in v1.2.7
func (t ThriftHandler) Register(dispatcher *yarpc.Dispatcher)
func (ThriftHandler) RemoveSignalMutableState ¶ added in v0.17.0
func (g ThriftHandler) RemoveSignalMutableState(ctx context.Context, RemoveRequest *history.RemoveSignalMutableStateRequest) (err error)
func (ThriftHandler) RemoveTask ¶ added in v0.17.0
func (g ThriftHandler) RemoveTask(ctx context.Context, Request *shared.RemoveTaskRequest) (err error)
func (ThriftHandler) ReplicateEventsV2 ¶ added in v0.17.0
func (g ThriftHandler) ReplicateEventsV2(ctx context.Context, ReplicateV2Request *history.ReplicateEventsV2Request) (err error)
func (ThriftHandler) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) RequestCancelWorkflowExecution(ctx context.Context, CancelRequest *history.RequestCancelWorkflowExecutionRequest) (err error)
func (ThriftHandler) ResetQueue ¶ added in v0.17.0
func (g ThriftHandler) ResetQueue(ctx context.Context, Request *shared.ResetQueueRequest) (err error)
func (ThriftHandler) ResetStickyTaskList ¶ added in v0.17.0
func (g ThriftHandler) ResetStickyTaskList(ctx context.Context, ResetRequest *history.ResetStickyTaskListRequest) (rp1 *history.ResetStickyTaskListResponse, err error)
func (ThriftHandler) ResetWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) ResetWorkflowExecution(ctx context.Context, ResetRequest *history.ResetWorkflowExecutionRequest) (rp1 *shared.ResetWorkflowExecutionResponse, err error)
func (ThriftHandler) RespondActivityTaskCanceled ¶ added in v0.17.0
func (g ThriftHandler) RespondActivityTaskCanceled(ctx context.Context, CanceledRequest *history.RespondActivityTaskCanceledRequest) (err error)
func (ThriftHandler) RespondActivityTaskCompleted ¶ added in v0.17.0
func (g ThriftHandler) RespondActivityTaskCompleted(ctx context.Context, CompleteRequest *history.RespondActivityTaskCompletedRequest) (err error)
func (ThriftHandler) RespondActivityTaskFailed ¶ added in v0.17.0
func (g ThriftHandler) RespondActivityTaskFailed(ctx context.Context, FailRequest *history.RespondActivityTaskFailedRequest) (err error)
func (ThriftHandler) RespondCrossClusterTasksCompleted ¶ added in v0.22.0
func (g ThriftHandler) RespondCrossClusterTasksCompleted(ctx context.Context, Request *shared.RespondCrossClusterTasksCompletedRequest) (rp1 *shared.RespondCrossClusterTasksCompletedResponse, err error)
func (ThriftHandler) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (g ThriftHandler) RespondDecisionTaskCompleted(ctx context.Context, CompleteRequest *history.RespondDecisionTaskCompletedRequest) (rp1 *history.RespondDecisionTaskCompletedResponse, err error)
func (ThriftHandler) RespondDecisionTaskFailed ¶ added in v0.17.0
func (g ThriftHandler) RespondDecisionTaskFailed(ctx context.Context, FailedRequest *history.RespondDecisionTaskFailedRequest) (err error)
func (ThriftHandler) ScheduleDecisionTask ¶ added in v0.17.0
func (g ThriftHandler) ScheduleDecisionTask(ctx context.Context, ScheduleRequest *history.ScheduleDecisionTaskRequest) (err error)
func (ThriftHandler) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) SignalWithStartWorkflowExecution(ctx context.Context, SignalWithStartRequest *history.SignalWithStartWorkflowExecutionRequest) (sp1 *shared.StartWorkflowExecutionResponse, err error)
func (ThriftHandler) SignalWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) SignalWorkflowExecution(ctx context.Context, SignalRequest *history.SignalWorkflowExecutionRequest) (err error)
func (ThriftHandler) StartWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) StartWorkflowExecution(ctx context.Context, StartRequest *history.StartWorkflowExecutionRequest) (sp1 *shared.StartWorkflowExecutionResponse, err error)
func (ThriftHandler) SyncActivity ¶ added in v0.17.0
func (g ThriftHandler) SyncActivity(ctx context.Context, SyncActivityRequest *history.SyncActivityRequest) (err error)
func (ThriftHandler) SyncShardStatus ¶ added in v0.17.0
func (g ThriftHandler) SyncShardStatus(ctx context.Context, SyncShardStatusRequest *history.SyncShardStatusRequest) (err error)
func (ThriftHandler) TerminateWorkflowExecution ¶ added in v0.17.0
func (g ThriftHandler) TerminateWorkflowExecution(ctx context.Context, TerminateRequest *history.TerminateWorkflowExecutionRequest) (err error)
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package engine is a generated GoMock package.
|
Package engine is a generated GoMock package. |
Package events is a generated GoMock package.
|
Package events is a generated GoMock package. |
Package execution is a generated GoMock package.
|
Package execution is a generated GoMock package. |
Package failover is a generated GoMock package.
|
Package failover is a generated GoMock package. |
Package ndc is a generated GoMock package.
|
Package ndc is a generated GoMock package. |
Package queue is a generated GoMock package.
|
Package queue is a generated GoMock package. |
Package reset is a generated GoMock package.
|
Package reset is a generated GoMock package. |
Package shard is a generated GoMock package.
|
Package shard is a generated GoMock package. |
Package task is a generated GoMock package.
|
Package task is a generated GoMock package. |
Package workflowcache is a generated GoMock package.
|
Package workflowcache is a generated GoMock package. |