Documentation ¶
Overview ¶
Package history is a generated GoMock package.
Index ¶
- Constants
- type Client
- func NewClient(numberOfShards int, timeout time.Duration, clients common.ClientCache, ...) Client
- func NewErrorInjectionClient(client Client, errorRate float64, logger log.Logger) Client
- func NewGRPCClient(c historyv1.HistoryAPIYARPCClient) Client
- func NewMetricClient(client Client, metricsClient metrics.Client) Client
- func NewRetryableClient(client Client, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) Client
- func NewThriftClient(c historyserviceclient.Interface) Client
- type MockClient
- func (m *MockClient) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest, arg2 ...yarpc.CallOption) error
- func (m *MockClient) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest, ...) (*types.DescribeHistoryHostResponse, error)
- func (m *MockClient) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest, ...) (*types.DescribeMutableStateResponse, error)
- func (m *MockClient) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest, ...) (*types.DescribeQueueResponse, error)
- func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest, ...) (*types.DescribeWorkflowExecutionResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest, ...) (*types.GetDLQReplicationMessagesResponse, error)
- func (m *MockClient) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest, ...) (*types.GetMutableStateResponse, error)
- func (m *MockClient) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest, ...) (*types.GetReplicationMessagesResponse, error)
- func (m *MockClient) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest, ...) (*types.MergeDLQMessagesResponse, error)
- func (m *MockClient) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest, ...) error
- func (m *MockClient) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest, ...) (*types.PollMutableStateResponse, error)
- func (m *MockClient) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest, ...) error
- func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest, ...) (*types.HistoryQueryWorkflowResponse, error)
- func (m *MockClient) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest, ...) (*types.ReadDLQMessagesResponse, error)
- func (m *MockClient) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest, ...) error
- func (m *MockClient) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest, ...) (*types.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockClient) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest, ...) (*types.RecordActivityTaskStartedResponse, error)
- func (m *MockClient) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest, ...) error
- func (m *MockClient) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest, ...) (*types.RecordDecisionTaskStartedResponse, error)
- func (m *MockClient) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest, ...) error
- func (m *MockClient) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest, ...) error
- func (m *MockClient) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest, arg2 ...yarpc.CallOption) error
- func (m *MockClient) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request, ...) error
- func (m *MockClient) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest, ...) error
- func (m *MockClient) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest, arg2 ...yarpc.CallOption) error
- func (m *MockClient) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest, ...) (*types.HistoryResetStickyTaskListResponse, error)
- func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest, ...) (*types.ResetWorkflowExecutionResponse, error)
- func (m *MockClient) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest, ...) error
- func (m *MockClient) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest, ...) error
- func (m *MockClient) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest, ...) error
- func (m *MockClient) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest, ...) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
- func (m *MockClient) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest, ...) error
- func (m *MockClient) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest, ...) error
- func (m *MockClient) SignalWithStartWorkflowExecution(arg0 context.Context, ...) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockClient) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest, ...) error
- func (m *MockClient) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest, ...) (*types.StartWorkflowExecutionResponse, error)
- func (m *MockClient) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest, ...) error
- func (m *MockClient) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest, ...) error
- func (m *MockClient) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest, ...) error
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) CloseShard(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) MergeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) PollMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ReadDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ReapplyEvents(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RemoveTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ResetQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SyncActivity(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SyncShardStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
const ( // DefaultTimeout is the default timeout used to make calls DefaultTimeout = time.Second * 30 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { CloseShard(context.Context, *types.CloseShardRequest, ...yarpc.CallOption) error DescribeHistoryHost(context.Context, *types.DescribeHistoryHostRequest, ...yarpc.CallOption) (*types.DescribeHistoryHostResponse, error) DescribeMutableState(context.Context, *types.DescribeMutableStateRequest, ...yarpc.CallOption) (*types.DescribeMutableStateResponse, error) DescribeQueue(context.Context, *types.DescribeQueueRequest, ...yarpc.CallOption) (*types.DescribeQueueResponse, error) DescribeWorkflowExecution(context.Context, *types.HistoryDescribeWorkflowExecutionRequest, ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error) GetDLQReplicationMessages(context.Context, *types.GetDLQReplicationMessagesRequest, ...yarpc.CallOption) (*types.GetDLQReplicationMessagesResponse, error) GetMutableState(context.Context, *types.GetMutableStateRequest, ...yarpc.CallOption) (*types.GetMutableStateResponse, error) GetReplicationMessages(context.Context, *types.GetReplicationMessagesRequest, ...yarpc.CallOption) (*types.GetReplicationMessagesResponse, error) MergeDLQMessages(context.Context, *types.MergeDLQMessagesRequest, ...yarpc.CallOption) (*types.MergeDLQMessagesResponse, error) NotifyFailoverMarkers(context.Context, *types.NotifyFailoverMarkersRequest, ...yarpc.CallOption) error PollMutableState(context.Context, *types.PollMutableStateRequest, ...yarpc.CallOption) (*types.PollMutableStateResponse, error) PurgeDLQMessages(context.Context, *types.PurgeDLQMessagesRequest, ...yarpc.CallOption) error QueryWorkflow(context.Context, *types.HistoryQueryWorkflowRequest, ...yarpc.CallOption) (*types.HistoryQueryWorkflowResponse, error) ReadDLQMessages(context.Context, *types.ReadDLQMessagesRequest, ...yarpc.CallOption) (*types.ReadDLQMessagesResponse, error) ReapplyEvents(context.Context, *types.HistoryReapplyEventsRequest, ...yarpc.CallOption) error RecordActivityTaskHeartbeat(context.Context, *types.HistoryRecordActivityTaskHeartbeatRequest, ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error) RecordActivityTaskStarted(context.Context, *types.RecordActivityTaskStartedRequest, ...yarpc.CallOption) (*types.RecordActivityTaskStartedResponse, error) RecordChildExecutionCompleted(context.Context, *types.RecordChildExecutionCompletedRequest, ...yarpc.CallOption) error RecordDecisionTaskStarted(context.Context, *types.RecordDecisionTaskStartedRequest, ...yarpc.CallOption) (*types.RecordDecisionTaskStartedResponse, error) RefreshWorkflowTasks(context.Context, *types.HistoryRefreshWorkflowTasksRequest, ...yarpc.CallOption) error RemoveSignalMutableState(context.Context, *types.RemoveSignalMutableStateRequest, ...yarpc.CallOption) error RemoveTask(context.Context, *types.RemoveTaskRequest, ...yarpc.CallOption) error ReplicateEventsV2(context.Context, *types.ReplicateEventsV2Request, ...yarpc.CallOption) error RequestCancelWorkflowExecution(context.Context, *types.HistoryRequestCancelWorkflowExecutionRequest, ...yarpc.CallOption) error ResetQueue(context.Context, *types.ResetQueueRequest, ...yarpc.CallOption) error ResetStickyTaskList(context.Context, *types.HistoryResetStickyTaskListRequest, ...yarpc.CallOption) (*types.HistoryResetStickyTaskListResponse, error) ResetWorkflowExecution(context.Context, *types.HistoryResetWorkflowExecutionRequest, ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error) RespondActivityTaskCanceled(context.Context, *types.HistoryRespondActivityTaskCanceledRequest, ...yarpc.CallOption) error RespondActivityTaskCompleted(context.Context, *types.HistoryRespondActivityTaskCompletedRequest, ...yarpc.CallOption) error RespondActivityTaskFailed(context.Context, *types.HistoryRespondActivityTaskFailedRequest, ...yarpc.CallOption) error RespondDecisionTaskCompleted(context.Context, *types.HistoryRespondDecisionTaskCompletedRequest, ...yarpc.CallOption) (*types.HistoryRespondDecisionTaskCompletedResponse, error) RespondDecisionTaskFailed(context.Context, *types.HistoryRespondDecisionTaskFailedRequest, ...yarpc.CallOption) error ScheduleDecisionTask(context.Context, *types.ScheduleDecisionTaskRequest, ...yarpc.CallOption) error SignalWithStartWorkflowExecution(context.Context, *types.HistorySignalWithStartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error) SignalWorkflowExecution(context.Context, *types.HistorySignalWorkflowExecutionRequest, ...yarpc.CallOption) error StartWorkflowExecution(context.Context, *types.HistoryStartWorkflowExecutionRequest, ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error) SyncActivity(context.Context, *types.SyncActivityRequest, ...yarpc.CallOption) error SyncShardStatus(context.Context, *types.SyncShardStatusRequest, ...yarpc.CallOption) error TerminateWorkflowExecution(context.Context, *types.HistoryTerminateWorkflowExecutionRequest, ...yarpc.CallOption) error }
Client is the interface exposed by history service client
func NewClient ¶
func NewClient( numberOfShards int, timeout time.Duration, clients common.ClientCache, logger log.Logger, ) Client
NewClient creates a new history service TChannel client
func NewErrorInjectionClient ¶ added in v0.18.0
NewErrorInjectionClient creates a new instance of Client that injects fake error
func NewGRPCClient ¶ added in v0.21.0
func NewGRPCClient(c historyv1.HistoryAPIYARPCClient) Client
func NewMetricClient ¶
NewMetricClient creates a new instance of Client that emits metrics
func NewRetryableClient ¶ added in v0.3.14
func NewRetryableClient( client Client, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable, ) Client
NewRetryableClient creates a new instance of Client with retry policy
func NewThriftClient ¶ added in v0.17.0
func NewThriftClient(c historyserviceclient.Interface) Client
NewThriftClient creates a new instance of Client with thrift protocol
type MockClient ¶ added in v0.17.0
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface
func NewMockClient ¶ added in v0.17.0
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance
func (*MockClient) CloseShard ¶ added in v0.17.0
func (m *MockClient) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest, arg2 ...yarpc.CallOption) error
CloseShard mocks base method
func (*MockClient) DescribeHistoryHost ¶ added in v0.17.0
func (m *MockClient) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest, arg2 ...yarpc.CallOption) (*types.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method
func (*MockClient) DescribeMutableState ¶ added in v0.17.0
func (m *MockClient) DescribeMutableState(arg0 context.Context, arg1 *types.DescribeMutableStateRequest, arg2 ...yarpc.CallOption) (*types.DescribeMutableStateResponse, error)
DescribeMutableState mocks base method
func (*MockClient) DescribeQueue ¶ added in v0.17.0
func (m *MockClient) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest, arg2 ...yarpc.CallOption) (*types.DescribeQueueResponse, error)
DescribeQueue mocks base method
func (*MockClient) DescribeWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.HistoryDescribeWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method
func (*MockClient) EXPECT ¶ added in v0.17.0
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockClient) GetDLQReplicationMessages ¶ added in v0.17.0
func (m *MockClient) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest, arg2 ...yarpc.CallOption) (*types.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method
func (*MockClient) GetMutableState ¶ added in v0.17.0
func (m *MockClient) GetMutableState(arg0 context.Context, arg1 *types.GetMutableStateRequest, arg2 ...yarpc.CallOption) (*types.GetMutableStateResponse, error)
GetMutableState mocks base method
func (*MockClient) GetReplicationMessages ¶ added in v0.17.0
func (m *MockClient) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest, arg2 ...yarpc.CallOption) (*types.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method
func (*MockClient) MergeDLQMessages ¶ added in v0.17.0
func (m *MockClient) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest, arg2 ...yarpc.CallOption) (*types.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method
func (*MockClient) NotifyFailoverMarkers ¶ added in v0.17.0
func (m *MockClient) NotifyFailoverMarkers(arg0 context.Context, arg1 *types.NotifyFailoverMarkersRequest, arg2 ...yarpc.CallOption) error
NotifyFailoverMarkers mocks base method
func (*MockClient) PollMutableState ¶ added in v0.17.0
func (m *MockClient) PollMutableState(arg0 context.Context, arg1 *types.PollMutableStateRequest, arg2 ...yarpc.CallOption) (*types.PollMutableStateResponse, error)
PollMutableState mocks base method
func (*MockClient) PurgeDLQMessages ¶ added in v0.17.0
func (m *MockClient) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest, arg2 ...yarpc.CallOption) error
PurgeDLQMessages mocks base method
func (*MockClient) QueryWorkflow ¶ added in v0.17.0
func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.HistoryQueryWorkflowRequest, arg2 ...yarpc.CallOption) (*types.HistoryQueryWorkflowResponse, error)
QueryWorkflow mocks base method
func (*MockClient) ReadDLQMessages ¶ added in v0.17.0
func (m *MockClient) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest, arg2 ...yarpc.CallOption) (*types.ReadDLQMessagesResponse, error)
ReadDLQMessages mocks base method
func (*MockClient) ReapplyEvents ¶ added in v0.17.0
func (m *MockClient) ReapplyEvents(arg0 context.Context, arg1 *types.HistoryReapplyEventsRequest, arg2 ...yarpc.CallOption) error
ReapplyEvents mocks base method
func (*MockClient) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (m *MockClient) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *types.HistoryRecordActivityTaskHeartbeatRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method
func (*MockClient) RecordActivityTaskStarted ¶ added in v0.17.0
func (m *MockClient) RecordActivityTaskStarted(arg0 context.Context, arg1 *types.RecordActivityTaskStartedRequest, arg2 ...yarpc.CallOption) (*types.RecordActivityTaskStartedResponse, error)
RecordActivityTaskStarted mocks base method
func (*MockClient) RecordChildExecutionCompleted ¶ added in v0.17.0
func (m *MockClient) RecordChildExecutionCompleted(arg0 context.Context, arg1 *types.RecordChildExecutionCompletedRequest, arg2 ...yarpc.CallOption) error
RecordChildExecutionCompleted mocks base method
func (*MockClient) RecordDecisionTaskStarted ¶ added in v0.17.0
func (m *MockClient) RecordDecisionTaskStarted(arg0 context.Context, arg1 *types.RecordDecisionTaskStartedRequest, arg2 ...yarpc.CallOption) (*types.RecordDecisionTaskStartedResponse, error)
RecordDecisionTaskStarted mocks base method
func (*MockClient) RefreshWorkflowTasks ¶ added in v0.17.0
func (m *MockClient) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.HistoryRefreshWorkflowTasksRequest, arg2 ...yarpc.CallOption) error
RefreshWorkflowTasks mocks base method
func (*MockClient) RemoveSignalMutableState ¶ added in v0.17.0
func (m *MockClient) RemoveSignalMutableState(arg0 context.Context, arg1 *types.RemoveSignalMutableStateRequest, arg2 ...yarpc.CallOption) error
RemoveSignalMutableState mocks base method
func (*MockClient) RemoveTask ¶ added in v0.17.0
func (m *MockClient) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest, arg2 ...yarpc.CallOption) error
RemoveTask mocks base method
func (*MockClient) ReplicateEventsV2 ¶ added in v0.17.0
func (m *MockClient) ReplicateEventsV2(arg0 context.Context, arg1 *types.ReplicateEventsV2Request, arg2 ...yarpc.CallOption) error
ReplicateEventsV2 mocks base method
func (*MockClient) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *types.HistoryRequestCancelWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error
RequestCancelWorkflowExecution mocks base method
func (*MockClient) ResetQueue ¶ added in v0.17.0
func (m *MockClient) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest, arg2 ...yarpc.CallOption) error
ResetQueue mocks base method
func (*MockClient) ResetStickyTaskList ¶ added in v0.17.0
func (m *MockClient) ResetStickyTaskList(arg0 context.Context, arg1 *types.HistoryResetStickyTaskListRequest, arg2 ...yarpc.CallOption) (*types.HistoryResetStickyTaskListResponse, error)
ResetStickyTaskList mocks base method
func (*MockClient) ResetWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *types.HistoryResetWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method
func (*MockClient) RespondActivityTaskCanceled ¶ added in v0.17.0
func (m *MockClient) RespondActivityTaskCanceled(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCanceledRequest, arg2 ...yarpc.CallOption) error
RespondActivityTaskCanceled mocks base method
func (*MockClient) RespondActivityTaskCompleted ¶ added in v0.17.0
func (m *MockClient) RespondActivityTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskCompletedRequest, arg2 ...yarpc.CallOption) error
RespondActivityTaskCompleted mocks base method
func (*MockClient) RespondActivityTaskFailed ¶ added in v0.17.0
func (m *MockClient) RespondActivityTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondActivityTaskFailedRequest, arg2 ...yarpc.CallOption) error
RespondActivityTaskFailed mocks base method
func (*MockClient) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (m *MockClient) RespondDecisionTaskCompleted(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskCompletedRequest, arg2 ...yarpc.CallOption) (*types.HistoryRespondDecisionTaskCompletedResponse, error)
RespondDecisionTaskCompleted mocks base method
func (*MockClient) RespondDecisionTaskFailed ¶ added in v0.17.0
func (m *MockClient) RespondDecisionTaskFailed(arg0 context.Context, arg1 *types.HistoryRespondDecisionTaskFailedRequest, arg2 ...yarpc.CallOption) error
RespondDecisionTaskFailed mocks base method
func (*MockClient) ScheduleDecisionTask ¶ added in v0.17.0
func (m *MockClient) ScheduleDecisionTask(arg0 context.Context, arg1 *types.ScheduleDecisionTaskRequest, arg2 ...yarpc.CallOption) error
ScheduleDecisionTask mocks base method
func (*MockClient) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWithStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method
func (*MockClient) SignalWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) SignalWorkflowExecution(arg0 context.Context, arg1 *types.HistorySignalWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error
SignalWorkflowExecution mocks base method
func (*MockClient) StartWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) StartWorkflowExecution(arg0 context.Context, arg1 *types.HistoryStartWorkflowExecutionRequest, arg2 ...yarpc.CallOption) (*types.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method
func (*MockClient) SyncActivity ¶ added in v0.17.0
func (m *MockClient) SyncActivity(arg0 context.Context, arg1 *types.SyncActivityRequest, arg2 ...yarpc.CallOption) error
SyncActivity mocks base method
func (*MockClient) SyncShardStatus ¶ added in v0.17.0
func (m *MockClient) SyncShardStatus(arg0 context.Context, arg1 *types.SyncShardStatusRequest, arg2 ...yarpc.CallOption) error
SyncShardStatus mocks base method
func (*MockClient) TerminateWorkflowExecution ¶ added in v0.17.0
func (m *MockClient) TerminateWorkflowExecution(arg0 context.Context, arg1 *types.HistoryTerminateWorkflowExecutionRequest, arg2 ...yarpc.CallOption) error
TerminateWorkflowExecution mocks base method
type MockClientMockRecorder ¶ added in v0.17.0
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient
func (*MockClientMockRecorder) CloseShard ¶ added in v0.17.0
func (mr *MockClientMockRecorder) CloseShard(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard
func (*MockClientMockRecorder) DescribeHistoryHost ¶ added in v0.17.0
func (mr *MockClientMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost
func (*MockClientMockRecorder) DescribeMutableState ¶ added in v0.17.0
func (mr *MockClientMockRecorder) DescribeMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeMutableState indicates an expected call of DescribeMutableState
func (*MockClientMockRecorder) DescribeQueue ¶ added in v0.17.0
func (mr *MockClientMockRecorder) DescribeQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeQueue indicates an expected call of DescribeQueue
func (*MockClientMockRecorder) DescribeWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution
func (*MockClientMockRecorder) GetDLQReplicationMessages ¶ added in v0.17.0
func (mr *MockClientMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages
func (*MockClientMockRecorder) GetMutableState ¶ added in v0.17.0
func (mr *MockClientMockRecorder) GetMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetMutableState indicates an expected call of GetMutableState
func (*MockClientMockRecorder) GetReplicationMessages ¶ added in v0.17.0
func (mr *MockClientMockRecorder) GetReplicationMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages
func (*MockClientMockRecorder) MergeDLQMessages ¶ added in v0.17.0
func (mr *MockClientMockRecorder) MergeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages
func (*MockClientMockRecorder) NotifyFailoverMarkers ¶ added in v0.17.0
func (mr *MockClientMockRecorder) NotifyFailoverMarkers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
NotifyFailoverMarkers indicates an expected call of NotifyFailoverMarkers
func (*MockClientMockRecorder) PollMutableState ¶ added in v0.17.0
func (mr *MockClientMockRecorder) PollMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PollMutableState indicates an expected call of PollMutableState
func (*MockClientMockRecorder) PurgeDLQMessages ¶ added in v0.17.0
func (mr *MockClientMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages
func (*MockClientMockRecorder) QueryWorkflow ¶ added in v0.17.0
func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow
func (*MockClientMockRecorder) ReadDLQMessages ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ReadDLQMessages(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReadDLQMessages indicates an expected call of ReadDLQMessages
func (*MockClientMockRecorder) ReapplyEvents ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ReapplyEvents(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents
func (*MockClientMockRecorder) RecordActivityTaskHeartbeat ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat
func (*MockClientMockRecorder) RecordActivityTaskStarted ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RecordActivityTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted
func (*MockClientMockRecorder) RecordChildExecutionCompleted ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RecordChildExecutionCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted
func (*MockClientMockRecorder) RecordDecisionTaskStarted ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RecordDecisionTaskStarted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RecordDecisionTaskStarted indicates an expected call of RecordDecisionTaskStarted
func (*MockClientMockRecorder) RefreshWorkflowTasks ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks
func (*MockClientMockRecorder) RemoveSignalMutableState ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RemoveSignalMutableState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState
func (*MockClientMockRecorder) RemoveTask ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RemoveTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask
func (*MockClientMockRecorder) ReplicateEventsV2 ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ReplicateEventsV2(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReplicateEventsV2 indicates an expected call of ReplicateEventsV2
func (*MockClientMockRecorder) RequestCancelWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution
func (*MockClientMockRecorder) ResetQueue ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ResetQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ResetQueue indicates an expected call of ResetQueue
func (*MockClientMockRecorder) ResetStickyTaskList ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ResetStickyTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ResetStickyTaskList indicates an expected call of ResetStickyTaskList
func (*MockClientMockRecorder) ResetWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution
func (*MockClientMockRecorder) RespondActivityTaskCanceled ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled
func (*MockClientMockRecorder) RespondActivityTaskCompleted ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted
func (*MockClientMockRecorder) RespondActivityTaskFailed ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed
func (*MockClientMockRecorder) RespondDecisionTaskCompleted ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RespondDecisionTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RespondDecisionTaskCompleted indicates an expected call of RespondDecisionTaskCompleted
func (*MockClientMockRecorder) RespondDecisionTaskFailed ¶ added in v0.17.0
func (mr *MockClientMockRecorder) RespondDecisionTaskFailed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RespondDecisionTaskFailed indicates an expected call of RespondDecisionTaskFailed
func (*MockClientMockRecorder) ScheduleDecisionTask ¶ added in v0.17.0
func (mr *MockClientMockRecorder) ScheduleDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ScheduleDecisionTask indicates an expected call of ScheduleDecisionTask
func (*MockClientMockRecorder) SignalWithStartWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution
func (*MockClientMockRecorder) SignalWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution
func (*MockClientMockRecorder) StartWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution
func (*MockClientMockRecorder) SyncActivity ¶ added in v0.17.0
func (mr *MockClientMockRecorder) SyncActivity(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SyncActivity indicates an expected call of SyncActivity
func (*MockClientMockRecorder) SyncShardStatus ¶ added in v0.17.0
func (mr *MockClientMockRecorder) SyncShardStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SyncShardStatus indicates an expected call of SyncShardStatus
func (*MockClientMockRecorder) TerminateWorkflowExecution ¶ added in v0.17.0
func (mr *MockClientMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution