historyservicemock

package
v1.22.2 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package historyservicemock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockHistoryServiceClient 

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

MockHistoryServiceClient is a mock of HistoryServiceClient interface.

func NewMockHistoryServiceClient 

func NewMockHistoryServiceClient(ctrl *gomock.Controller) *MockHistoryServiceClient

NewMockHistoryServiceClient creates a new mock instance.

func (*MockHistoryServiceClient) CloseShard 

func (m *MockHistoryServiceClient) CloseShard(ctx context.Context, in *historyservice.CloseShardRequest, opts ...grpc.CallOption) (*historyservice.CloseShardResponse, error)

CloseShard mocks base method.

func (*MockHistoryServiceClient) DeleteWorkflowExecution added in v1.15.0 

func (m *MockHistoryServiceClient) DeleteWorkflowExecution(ctx context.Context, in *historyservice.DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.DeleteWorkflowExecutionResponse, error)

DeleteWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) DeleteWorkflowVisibilityRecord added in v1.17.0 

func (m *MockHistoryServiceClient) DeleteWorkflowVisibilityRecord(ctx context.Context, in *historyservice.DeleteWorkflowVisibilityRecordRequest, opts ...grpc.CallOption) (*historyservice.DeleteWorkflowVisibilityRecordResponse, error)

DeleteWorkflowVisibilityRecord mocks base method.

func (*MockHistoryServiceClient) DescribeHistoryHost 

func (m *MockHistoryServiceClient) DescribeHistoryHost(ctx context.Context, in *historyservice.DescribeHistoryHostRequest, opts ...grpc.CallOption) (*historyservice.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method.

func (*MockHistoryServiceClient) DescribeMutableState 

func (m *MockHistoryServiceClient) DescribeMutableState(ctx context.Context, in *historyservice.DescribeMutableStateRequest, opts ...grpc.CallOption) (*historyservice.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method.

func (*MockHistoryServiceClient) DescribeWorkflowExecution 

func (m *MockHistoryServiceClient) DescribeWorkflowExecution(ctx context.Context, in *historyservice.DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) EXPECT 

func (m *MockHistoryServiceClient) EXPECT() *MockHistoryServiceClientMockRecorder

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

func (*MockHistoryServiceClient) GenerateLastHistoryReplicationTasks added in v1.14.0 

func (m *MockHistoryServiceClient) GenerateLastHistoryReplicationTasks(ctx context.Context, in *historyservice.GenerateLastHistoryReplicationTasksRequest, opts ...grpc.CallOption) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error)

GenerateLastHistoryReplicationTasks mocks base method.

func (*MockHistoryServiceClient) GetDLQMessages 

func (m *MockHistoryServiceClient) GetDLQMessages(ctx context.Context, in *historyservice.GetDLQMessagesRequest, opts ...grpc.CallOption) (*historyservice.GetDLQMessagesResponse, error)

GetDLQMessages mocks base method.

func (*MockHistoryServiceClient) GetDLQReplicationMessages 

func (m *MockHistoryServiceClient) GetDLQReplicationMessages(ctx context.Context, in *historyservice.GetDLQReplicationMessagesRequest, opts ...grpc.CallOption) (*historyservice.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method.

func (*MockHistoryServiceClient) GetMutableState 

func (m *MockHistoryServiceClient) GetMutableState(ctx context.Context, in *historyservice.GetMutableStateRequest, opts ...grpc.CallOption) (*historyservice.GetMutableStateResponse, error)

GetMutableState mocks base method.

func (*MockHistoryServiceClient) GetReplicationMessages 

func (m *MockHistoryServiceClient) GetReplicationMessages(ctx context.Context, in *historyservice.GetReplicationMessagesRequest, opts ...grpc.CallOption) (*historyservice.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method.

func (*MockHistoryServiceClient) GetReplicationStatus added in v1.14.0 

func (m *MockHistoryServiceClient) GetReplicationStatus(ctx context.Context, in *historyservice.GetReplicationStatusRequest, opts ...grpc.CallOption) (*historyservice.GetReplicationStatusResponse, error)

GetReplicationStatus mocks base method.

func (*MockHistoryServiceClient) GetShard added in v1.14.0 

func (m *MockHistoryServiceClient) GetShard(ctx context.Context, in *historyservice.GetShardRequest, opts ...grpc.CallOption) (*historyservice.GetShardResponse, error)

GetShard mocks base method.

func (*MockHistoryServiceClient) IsActivityTaskValid added in v1.22.0 

func (m *MockHistoryServiceClient) IsActivityTaskValid(ctx context.Context, in *historyservice.IsActivityTaskValidRequest, opts ...grpc.CallOption) (*historyservice.IsActivityTaskValidResponse, error)

IsActivityTaskValid mocks base method.

func (*MockHistoryServiceClient) IsWorkflowTaskValid added in v1.22.0 

func (m *MockHistoryServiceClient) IsWorkflowTaskValid(ctx context.Context, in *historyservice.IsWorkflowTaskValidRequest, opts ...grpc.CallOption) (*historyservice.IsWorkflowTaskValidResponse, error)

IsWorkflowTaskValid mocks base method.

func (*MockHistoryServiceClient) MergeDLQMessages 

func (m *MockHistoryServiceClient) MergeDLQMessages(ctx context.Context, in *historyservice.MergeDLQMessagesRequest, opts ...grpc.CallOption) (*historyservice.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method.

func (*MockHistoryServiceClient) PollMutableState 

func (m *MockHistoryServiceClient) PollMutableState(ctx context.Context, in *historyservice.PollMutableStateRequest, opts ...grpc.CallOption) (*historyservice.PollMutableStateResponse, error)

PollMutableState mocks base method.

func (*MockHistoryServiceClient) PollWorkflowExecutionUpdate added in v1.21.0 

func (m *MockHistoryServiceClient) PollWorkflowExecutionUpdate(ctx context.Context, in *historyservice.PollWorkflowExecutionUpdateRequest, opts ...grpc.CallOption) (*historyservice.PollWorkflowExecutionUpdateResponse, error)

PollWorkflowExecutionUpdate mocks base method.

func (*MockHistoryServiceClient) PurgeDLQMessages 

func (m *MockHistoryServiceClient) PurgeDLQMessages(ctx context.Context, in *historyservice.PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*historyservice.PurgeDLQMessagesResponse, error)

PurgeDLQMessages mocks base method.

func (*MockHistoryServiceClient) QueryWorkflow 

func (m *MockHistoryServiceClient) QueryWorkflow(ctx context.Context, in *historyservice.QueryWorkflowRequest, opts ...grpc.CallOption) (*historyservice.QueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockHistoryServiceClient) ReapplyEvents 

func (m *MockHistoryServiceClient) ReapplyEvents(ctx context.Context, in *historyservice.ReapplyEventsRequest, opts ...grpc.CallOption) (*historyservice.ReapplyEventsResponse, error)

ReapplyEvents mocks base method.

func (*MockHistoryServiceClient) RebuildMutableState added in v1.16.0 

func (m *MockHistoryServiceClient) RebuildMutableState(ctx context.Context, in *historyservice.RebuildMutableStateRequest, opts ...grpc.CallOption) (*historyservice.RebuildMutableStateResponse, error)

RebuildMutableState mocks base method.

func (*MockHistoryServiceClient) RecordActivityTaskHeartbeat 

func (m *MockHistoryServiceClient) RecordActivityTaskHeartbeat(ctx context.Context, in *historyservice.RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*historyservice.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method.

func (*MockHistoryServiceClient) RecordActivityTaskStarted 

func (m *MockHistoryServiceClient) RecordActivityTaskStarted(ctx context.Context, in *historyservice.RecordActivityTaskStartedRequest, opts ...grpc.CallOption) (*historyservice.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method.

func (*MockHistoryServiceClient) RecordChildExecutionCompleted 

func (m *MockHistoryServiceClient) RecordChildExecutionCompleted(ctx context.Context, in *historyservice.RecordChildExecutionCompletedRequest, opts ...grpc.CallOption) (*historyservice.RecordChildExecutionCompletedResponse, error)

RecordChildExecutionCompleted mocks base method.

func (*MockHistoryServiceClient) RecordWorkflowTaskStarted 

func (m *MockHistoryServiceClient) RecordWorkflowTaskStarted(ctx context.Context, in *historyservice.RecordWorkflowTaskStartedRequest, opts ...grpc.CallOption) (*historyservice.RecordWorkflowTaskStartedResponse, error)

RecordWorkflowTaskStarted mocks base method.

func (*MockHistoryServiceClient) RefreshWorkflowTasks 

func (m *MockHistoryServiceClient) RefreshWorkflowTasks(ctx context.Context, in *historyservice.RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*historyservice.RefreshWorkflowTasksResponse, error)

RefreshWorkflowTasks mocks base method.

func (*MockHistoryServiceClient) RemoveSignalMutableState 

func (m *MockHistoryServiceClient) RemoveSignalMutableState(ctx context.Context, in *historyservice.RemoveSignalMutableStateRequest, opts ...grpc.CallOption) (*historyservice.RemoveSignalMutableStateResponse, error)

RemoveSignalMutableState mocks base method.

func (*MockHistoryServiceClient) RemoveTask 

func (m *MockHistoryServiceClient) RemoveTask(ctx context.Context, in *historyservice.RemoveTaskRequest, opts ...grpc.CallOption) (*historyservice.RemoveTaskResponse, error)

RemoveTask mocks base method.

func (*MockHistoryServiceClient) ReplicateEventsV2 

func (m *MockHistoryServiceClient) ReplicateEventsV2(ctx context.Context, in *historyservice.ReplicateEventsV2Request, opts ...grpc.CallOption) (*historyservice.ReplicateEventsV2Response, error)

ReplicateEventsV2 mocks base method.

func (*MockHistoryServiceClient) ReplicateWorkflowState added in v1.20.0 

func (m *MockHistoryServiceClient) ReplicateWorkflowState(ctx context.Context, in *historyservice.ReplicateWorkflowStateRequest, opts ...grpc.CallOption) (*historyservice.ReplicateWorkflowStateResponse, error)

ReplicateWorkflowState mocks base method.

func (*MockHistoryServiceClient) RequestCancelWorkflowExecution 

func (m *MockHistoryServiceClient) RequestCancelWorkflowExecution(ctx context.Context, in *historyservice.RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.RequestCancelWorkflowExecutionResponse, error)

RequestCancelWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) ResetStickyTaskQueue 

func (m *MockHistoryServiceClient) ResetStickyTaskQueue(ctx context.Context, in *historyservice.ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*historyservice.ResetStickyTaskQueueResponse, error)

ResetStickyTaskQueue mocks base method.

func (*MockHistoryServiceClient) ResetWorkflowExecution 

func (m *MockHistoryServiceClient) ResetWorkflowExecution(ctx context.Context, in *historyservice.ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) RespondActivityTaskCanceled 

func (m *MockHistoryServiceClient) RespondActivityTaskCanceled(ctx context.Context, in *historyservice.RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*historyservice.RespondActivityTaskCanceledResponse, error)

RespondActivityTaskCanceled mocks base method.

func (*MockHistoryServiceClient) RespondActivityTaskCompleted 

func (m *MockHistoryServiceClient) RespondActivityTaskCompleted(ctx context.Context, in *historyservice.RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*historyservice.RespondActivityTaskCompletedResponse, error)

RespondActivityTaskCompleted mocks base method.

func (*MockHistoryServiceClient) RespondActivityTaskFailed 

func (m *MockHistoryServiceClient) RespondActivityTaskFailed(ctx context.Context, in *historyservice.RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*historyservice.RespondActivityTaskFailedResponse, error)

RespondActivityTaskFailed mocks base method.

func (*MockHistoryServiceClient) RespondWorkflowTaskCompleted 

func (m *MockHistoryServiceClient) RespondWorkflowTaskCompleted(ctx context.Context, in *historyservice.RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*historyservice.RespondWorkflowTaskCompletedResponse, error)

RespondWorkflowTaskCompleted mocks base method.

func (*MockHistoryServiceClient) RespondWorkflowTaskFailed 

func (m *MockHistoryServiceClient) RespondWorkflowTaskFailed(ctx context.Context, in *historyservice.RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*historyservice.RespondWorkflowTaskFailedResponse, error)

RespondWorkflowTaskFailed mocks base method.

func (*MockHistoryServiceClient) ScheduleWorkflowTask 

func (m *MockHistoryServiceClient) ScheduleWorkflowTask(ctx context.Context, in *historyservice.ScheduleWorkflowTaskRequest, opts ...grpc.CallOption) (*historyservice.ScheduleWorkflowTaskResponse, error)

ScheduleWorkflowTask mocks base method.

func (*MockHistoryServiceClient) SignalWithStartWorkflowExecution 

func (m *MockHistoryServiceClient) SignalWithStartWorkflowExecution(ctx context.Context, in *historyservice.SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.SignalWithStartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) SignalWorkflowExecution 

func (m *MockHistoryServiceClient) SignalWorkflowExecution(ctx context.Context, in *historyservice.SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.SignalWorkflowExecutionResponse, error)

SignalWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) StartWorkflowExecution 

func (m *MockHistoryServiceClient) StartWorkflowExecution(ctx context.Context, in *historyservice.StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) StreamWorkflowReplicationMessages added in v1.21.0 

func (m *MockHistoryServiceClient) StreamWorkflowReplicationMessages(ctx context.Context, opts ...grpc.CallOption) (historyservice.HistoryService_StreamWorkflowReplicationMessagesClient, error)

StreamWorkflowReplicationMessages mocks base method.

func (*MockHistoryServiceClient) SyncActivity 

func (m *MockHistoryServiceClient) SyncActivity(ctx context.Context, in *historyservice.SyncActivityRequest, opts ...grpc.CallOption) (*historyservice.SyncActivityResponse, error)

SyncActivity mocks base method.

func (*MockHistoryServiceClient) SyncShardStatus 

func (m *MockHistoryServiceClient) SyncShardStatus(ctx context.Context, in *historyservice.SyncShardStatusRequest, opts ...grpc.CallOption) (*historyservice.SyncShardStatusResponse, error)

SyncShardStatus mocks base method.

func (*MockHistoryServiceClient) TerminateWorkflowExecution 

func (m *MockHistoryServiceClient) TerminateWorkflowExecution(ctx context.Context, in *historyservice.TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.TerminateWorkflowExecutionResponse, error)

TerminateWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) UpdateWorkflowExecution added in v1.20.0 

func (m *MockHistoryServiceClient) UpdateWorkflowExecution(ctx context.Context, in *historyservice.UpdateWorkflowExecutionRequest, opts ...grpc.CallOption) (*historyservice.UpdateWorkflowExecutionResponse, error)

UpdateWorkflowExecution mocks base method.

func (*MockHistoryServiceClient) VerifyChildExecutionCompletionRecorded added in v1.17.0 

func (m *MockHistoryServiceClient) VerifyChildExecutionCompletionRecorded(ctx context.Context, in *historyservice.VerifyChildExecutionCompletionRecordedRequest, opts ...grpc.CallOption) (*historyservice.VerifyChildExecutionCompletionRecordedResponse, error)

VerifyChildExecutionCompletionRecorded mocks base method.

func (*MockHistoryServiceClient) VerifyFirstWorkflowTaskScheduled added in v1.17.0 

func (m *MockHistoryServiceClient) VerifyFirstWorkflowTaskScheduled(ctx context.Context, in *historyservice.VerifyFirstWorkflowTaskScheduledRequest, opts ...grpc.CallOption) (*historyservice.VerifyFirstWorkflowTaskScheduledResponse, error)

VerifyFirstWorkflowTaskScheduled mocks base method.

type MockHistoryServiceClientMockRecorder 

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

MockHistoryServiceClientMockRecorder is the mock recorder for MockHistoryServiceClient.

func (*MockHistoryServiceClientMockRecorder) CloseShard 

func (mr *MockHistoryServiceClientMockRecorder) CloseShard(ctx, in interface{}, opts ...interface{}) *gomock.Call

CloseShard indicates an expected call of CloseShard.

func (*MockHistoryServiceClientMockRecorder) DeleteWorkflowExecution added in v1.15.0 

func (mr *MockHistoryServiceClientMockRecorder) DeleteWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) DeleteWorkflowVisibilityRecord added in v1.17.0 

func (mr *MockHistoryServiceClientMockRecorder) DeleteWorkflowVisibilityRecord(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteWorkflowVisibilityRecord indicates an expected call of DeleteWorkflowVisibilityRecord.

func (*MockHistoryServiceClientMockRecorder) DescribeHistoryHost 

func (mr *MockHistoryServiceClientMockRecorder) DescribeHistoryHost(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeHistoryHost indicates an expected call of DescribeHistoryHost.

func (*MockHistoryServiceClientMockRecorder) DescribeMutableState 

func (mr *MockHistoryServiceClientMockRecorder) DescribeMutableState(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeMutableState indicates an expected call of DescribeMutableState.

func (*MockHistoryServiceClientMockRecorder) DescribeWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) DescribeWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) GenerateLastHistoryReplicationTasks added in v1.14.0 

func (mr *MockHistoryServiceClientMockRecorder) GenerateLastHistoryReplicationTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

GenerateLastHistoryReplicationTasks indicates an expected call of GenerateLastHistoryReplicationTasks.

func (*MockHistoryServiceClientMockRecorder) GetDLQMessages 

func (mr *MockHistoryServiceClientMockRecorder) GetDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetDLQMessages indicates an expected call of GetDLQMessages.

func (*MockHistoryServiceClientMockRecorder) GetDLQReplicationMessages 

func (mr *MockHistoryServiceClientMockRecorder) GetDLQReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.

func (*MockHistoryServiceClientMockRecorder) GetMutableState 

func (mr *MockHistoryServiceClientMockRecorder) GetMutableState(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetMutableState indicates an expected call of GetMutableState.

func (*MockHistoryServiceClientMockRecorder) GetReplicationMessages 

func (mr *MockHistoryServiceClientMockRecorder) GetReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetReplicationMessages indicates an expected call of GetReplicationMessages.

func (*MockHistoryServiceClientMockRecorder) GetReplicationStatus added in v1.14.0 

func (mr *MockHistoryServiceClientMockRecorder) GetReplicationStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetReplicationStatus indicates an expected call of GetReplicationStatus.

func (*MockHistoryServiceClientMockRecorder) GetShard added in v1.14.0 

func (mr *MockHistoryServiceClientMockRecorder) GetShard(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetShard indicates an expected call of GetShard.

func (*MockHistoryServiceClientMockRecorder) IsActivityTaskValid added in v1.22.0 

func (mr *MockHistoryServiceClientMockRecorder) IsActivityTaskValid(ctx, in interface{}, opts ...interface{}) *gomock.Call

IsActivityTaskValid indicates an expected call of IsActivityTaskValid.

func (*MockHistoryServiceClientMockRecorder) IsWorkflowTaskValid added in v1.22.0 

func (mr *MockHistoryServiceClientMockRecorder) IsWorkflowTaskValid(ctx, in interface{}, opts ...interface{}) *gomock.Call

IsWorkflowTaskValid indicates an expected call of IsWorkflowTaskValid.

func (*MockHistoryServiceClientMockRecorder) MergeDLQMessages 

func (mr *MockHistoryServiceClientMockRecorder) MergeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call

MergeDLQMessages indicates an expected call of MergeDLQMessages.

func (*MockHistoryServiceClientMockRecorder) PollMutableState 

func (mr *MockHistoryServiceClientMockRecorder) PollMutableState(ctx, in interface{}, opts ...interface{}) *gomock.Call

PollMutableState indicates an expected call of PollMutableState.

func (*MockHistoryServiceClientMockRecorder) PollWorkflowExecutionUpdate added in v1.21.0 

func (mr *MockHistoryServiceClientMockRecorder) PollWorkflowExecutionUpdate(ctx, in interface{}, opts ...interface{}) *gomock.Call

PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.

func (*MockHistoryServiceClientMockRecorder) PurgeDLQMessages 

func (mr *MockHistoryServiceClientMockRecorder) PurgeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call

PurgeDLQMessages indicates an expected call of PurgeDLQMessages.

func (*MockHistoryServiceClientMockRecorder) QueryWorkflow 

func (mr *MockHistoryServiceClientMockRecorder) QueryWorkflow(ctx, in interface{}, opts ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockHistoryServiceClientMockRecorder) ReapplyEvents 

func (mr *MockHistoryServiceClientMockRecorder) ReapplyEvents(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockHistoryServiceClientMockRecorder) RebuildMutableState added in v1.16.0 

func (mr *MockHistoryServiceClientMockRecorder) RebuildMutableState(ctx, in interface{}, opts ...interface{}) *gomock.Call

RebuildMutableState indicates an expected call of RebuildMutableState.

func (*MockHistoryServiceClientMockRecorder) RecordActivityTaskHeartbeat 

func (mr *MockHistoryServiceClientMockRecorder) RecordActivityTaskHeartbeat(ctx, in interface{}, opts ...interface{}) *gomock.Call

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockHistoryServiceClientMockRecorder) RecordActivityTaskStarted 

func (mr *MockHistoryServiceClientMockRecorder) RecordActivityTaskStarted(ctx, in interface{}, opts ...interface{}) *gomock.Call

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.

func (*MockHistoryServiceClientMockRecorder) RecordChildExecutionCompleted 

func (mr *MockHistoryServiceClientMockRecorder) RecordChildExecutionCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.

func (*MockHistoryServiceClientMockRecorder) RecordWorkflowTaskStarted 

func (mr *MockHistoryServiceClientMockRecorder) RecordWorkflowTaskStarted(ctx, in interface{}, opts ...interface{}) *gomock.Call

RecordWorkflowTaskStarted indicates an expected call of RecordWorkflowTaskStarted.

func (*MockHistoryServiceClientMockRecorder) RefreshWorkflowTasks 

func (mr *MockHistoryServiceClientMockRecorder) RefreshWorkflowTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockHistoryServiceClientMockRecorder) RemoveSignalMutableState 

func (mr *MockHistoryServiceClientMockRecorder) RemoveSignalMutableState(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.

func (*MockHistoryServiceClientMockRecorder) RemoveTask 

func (mr *MockHistoryServiceClientMockRecorder) RemoveTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveTask indicates an expected call of RemoveTask.

func (*MockHistoryServiceClientMockRecorder) ReplicateEventsV2 

func (mr *MockHistoryServiceClientMockRecorder) ReplicateEventsV2(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.

func (*MockHistoryServiceClientMockRecorder) ReplicateWorkflowState added in v1.20.0 

func (mr *MockHistoryServiceClientMockRecorder) ReplicateWorkflowState(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReplicateWorkflowState indicates an expected call of ReplicateWorkflowState.

func (*MockHistoryServiceClientMockRecorder) RequestCancelWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) RequestCancelWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) ResetStickyTaskQueue 

func (mr *MockHistoryServiceClientMockRecorder) ResetStickyTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.

func (*MockHistoryServiceClientMockRecorder) ResetWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) ResetWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) RespondActivityTaskCanceled 

func (mr *MockHistoryServiceClientMockRecorder) RespondActivityTaskCanceled(ctx, in interface{}, opts ...interface{}) *gomock.Call

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockHistoryServiceClientMockRecorder) RespondActivityTaskCompleted 

func (mr *MockHistoryServiceClientMockRecorder) RespondActivityTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockHistoryServiceClientMockRecorder) RespondActivityTaskFailed 

func (mr *MockHistoryServiceClientMockRecorder) RespondActivityTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockHistoryServiceClientMockRecorder) RespondWorkflowTaskCompleted 

func (mr *MockHistoryServiceClientMockRecorder) RespondWorkflowTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call

RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.

func (*MockHistoryServiceClientMockRecorder) RespondWorkflowTaskFailed 

func (mr *MockHistoryServiceClientMockRecorder) RespondWorkflowTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call

RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.

func (*MockHistoryServiceClientMockRecorder) ScheduleWorkflowTask 

func (mr *MockHistoryServiceClientMockRecorder) ScheduleWorkflowTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

ScheduleWorkflowTask indicates an expected call of ScheduleWorkflowTask.

func (*MockHistoryServiceClientMockRecorder) SignalWithStartWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) SignalWithStartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) SignalWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) SignalWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) StartWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) StartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) StreamWorkflowReplicationMessages added in v1.21.0 

func (mr *MockHistoryServiceClientMockRecorder) StreamWorkflowReplicationMessages(ctx interface{}, opts ...interface{}) *gomock.Call

StreamWorkflowReplicationMessages indicates an expected call of StreamWorkflowReplicationMessages.

func (*MockHistoryServiceClientMockRecorder) SyncActivity 

func (mr *MockHistoryServiceClientMockRecorder) SyncActivity(ctx, in interface{}, opts ...interface{}) *gomock.Call

SyncActivity indicates an expected call of SyncActivity.

func (*MockHistoryServiceClientMockRecorder) SyncShardStatus 

func (mr *MockHistoryServiceClientMockRecorder) SyncShardStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call

SyncShardStatus indicates an expected call of SyncShardStatus.

func (*MockHistoryServiceClientMockRecorder) TerminateWorkflowExecution 

func (mr *MockHistoryServiceClientMockRecorder) TerminateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) UpdateWorkflowExecution added in v1.20.0 

func (mr *MockHistoryServiceClientMockRecorder) UpdateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

func (*MockHistoryServiceClientMockRecorder) VerifyChildExecutionCompletionRecorded added in v1.17.0 

func (mr *MockHistoryServiceClientMockRecorder) VerifyChildExecutionCompletionRecorded(ctx, in interface{}, opts ...interface{}) *gomock.Call

VerifyChildExecutionCompletionRecorded indicates an expected call of VerifyChildExecutionCompletionRecorded.

func (*MockHistoryServiceClientMockRecorder) VerifyFirstWorkflowTaskScheduled added in v1.17.0 

func (mr *MockHistoryServiceClientMockRecorder) VerifyFirstWorkflowTaskScheduled(ctx, in interface{}, opts ...interface{}) *gomock.Call

VerifyFirstWorkflowTaskScheduled indicates an expected call of VerifyFirstWorkflowTaskScheduled.

type MockHistoryServiceServer 

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

MockHistoryServiceServer is a mock of HistoryServiceServer interface.

func NewMockHistoryServiceServer 

func NewMockHistoryServiceServer(ctrl *gomock.Controller) *MockHistoryServiceServer

NewMockHistoryServiceServer creates a new mock instance.

func (*MockHistoryServiceServer) CloseShard 

func (m *MockHistoryServiceServer) CloseShard(arg0 context.Context, arg1 *historyservice.CloseShardRequest) (*historyservice.CloseShardResponse, error)

CloseShard mocks base method.

func (*MockHistoryServiceServer) DeleteWorkflowExecution added in v1.15.0 

func (m *MockHistoryServiceServer) DeleteWorkflowExecution(arg0 context.Context, arg1 *historyservice.DeleteWorkflowExecutionRequest) (*historyservice.DeleteWorkflowExecutionResponse, error)

DeleteWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) DeleteWorkflowVisibilityRecord added in v1.17.0 

func (m *MockHistoryServiceServer) DeleteWorkflowVisibilityRecord(arg0 context.Context, arg1 *historyservice.DeleteWorkflowVisibilityRecordRequest) (*historyservice.DeleteWorkflowVisibilityRecordResponse, error)

DeleteWorkflowVisibilityRecord mocks base method.

func (*MockHistoryServiceServer) DescribeHistoryHost 

func (m *MockHistoryServiceServer) DescribeHistoryHost(arg0 context.Context, arg1 *historyservice.DescribeHistoryHostRequest) (*historyservice.DescribeHistoryHostResponse, error)

DescribeHistoryHost mocks base method.

func (*MockHistoryServiceServer) DescribeMutableState 

func (m *MockHistoryServiceServer) DescribeMutableState(arg0 context.Context, arg1 *historyservice.DescribeMutableStateRequest) (*historyservice.DescribeMutableStateResponse, error)

DescribeMutableState mocks base method.

func (*MockHistoryServiceServer) DescribeWorkflowExecution 

func (m *MockHistoryServiceServer) DescribeWorkflowExecution(arg0 context.Context, arg1 *historyservice.DescribeWorkflowExecutionRequest) (*historyservice.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) EXPECT 

func (m *MockHistoryServiceServer) EXPECT() *MockHistoryServiceServerMockRecorder

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

func (*MockHistoryServiceServer) GenerateLastHistoryReplicationTasks added in v1.14.0 

func (m *MockHistoryServiceServer) GenerateLastHistoryReplicationTasks(arg0 context.Context, arg1 *historyservice.GenerateLastHistoryReplicationTasksRequest) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error)

GenerateLastHistoryReplicationTasks mocks base method.

func (*MockHistoryServiceServer) GetDLQMessages 

func (m *MockHistoryServiceServer) GetDLQMessages(arg0 context.Context, arg1 *historyservice.GetDLQMessagesRequest) (*historyservice.GetDLQMessagesResponse, error)

GetDLQMessages mocks base method.

func (*MockHistoryServiceServer) GetDLQReplicationMessages 

func (m *MockHistoryServiceServer) GetDLQReplicationMessages(arg0 context.Context, arg1 *historyservice.GetDLQReplicationMessagesRequest) (*historyservice.GetDLQReplicationMessagesResponse, error)

GetDLQReplicationMessages mocks base method.

func (*MockHistoryServiceServer) GetMutableState 

func (m *MockHistoryServiceServer) GetMutableState(arg0 context.Context, arg1 *historyservice.GetMutableStateRequest) (*historyservice.GetMutableStateResponse, error)

GetMutableState mocks base method.

func (*MockHistoryServiceServer) GetReplicationMessages 

func (m *MockHistoryServiceServer) GetReplicationMessages(arg0 context.Context, arg1 *historyservice.GetReplicationMessagesRequest) (*historyservice.GetReplicationMessagesResponse, error)

GetReplicationMessages mocks base method.

func (*MockHistoryServiceServer) GetReplicationStatus added in v1.14.0 

func (m *MockHistoryServiceServer) GetReplicationStatus(arg0 context.Context, arg1 *historyservice.GetReplicationStatusRequest) (*historyservice.GetReplicationStatusResponse, error)

GetReplicationStatus mocks base method.

func (*MockHistoryServiceServer) GetShard added in v1.14.0 

func (m *MockHistoryServiceServer) GetShard(arg0 context.Context, arg1 *historyservice.GetShardRequest) (*historyservice.GetShardResponse, error)

GetShard mocks base method.

func (*MockHistoryServiceServer) IsActivityTaskValid added in v1.22.0 

func (m *MockHistoryServiceServer) IsActivityTaskValid(arg0 context.Context, arg1 *historyservice.IsActivityTaskValidRequest) (*historyservice.IsActivityTaskValidResponse, error)

IsActivityTaskValid mocks base method.

func (*MockHistoryServiceServer) IsWorkflowTaskValid added in v1.22.0 

func (m *MockHistoryServiceServer) IsWorkflowTaskValid(arg0 context.Context, arg1 *historyservice.IsWorkflowTaskValidRequest) (*historyservice.IsWorkflowTaskValidResponse, error)

IsWorkflowTaskValid mocks base method.

func (*MockHistoryServiceServer) MergeDLQMessages 

func (m *MockHistoryServiceServer) MergeDLQMessages(arg0 context.Context, arg1 *historyservice.MergeDLQMessagesRequest) (*historyservice.MergeDLQMessagesResponse, error)

MergeDLQMessages mocks base method.

func (*MockHistoryServiceServer) PollMutableState 

func (m *MockHistoryServiceServer) PollMutableState(arg0 context.Context, arg1 *historyservice.PollMutableStateRequest) (*historyservice.PollMutableStateResponse, error)

PollMutableState mocks base method.

func (*MockHistoryServiceServer) PollWorkflowExecutionUpdate added in v1.21.0 

func (m *MockHistoryServiceServer) PollWorkflowExecutionUpdate(arg0 context.Context, arg1 *historyservice.PollWorkflowExecutionUpdateRequest) (*historyservice.PollWorkflowExecutionUpdateResponse, error)

PollWorkflowExecutionUpdate mocks base method.

func (*MockHistoryServiceServer) PurgeDLQMessages 

func (m *MockHistoryServiceServer) PurgeDLQMessages(arg0 context.Context, arg1 *historyservice.PurgeDLQMessagesRequest) (*historyservice.PurgeDLQMessagesResponse, error)

PurgeDLQMessages mocks base method.

func (*MockHistoryServiceServer) QueryWorkflow 

func (m *MockHistoryServiceServer) QueryWorkflow(arg0 context.Context, arg1 *historyservice.QueryWorkflowRequest) (*historyservice.QueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockHistoryServiceServer) ReapplyEvents 

func (m *MockHistoryServiceServer) ReapplyEvents(arg0 context.Context, arg1 *historyservice.ReapplyEventsRequest) (*historyservice.ReapplyEventsResponse, error)

ReapplyEvents mocks base method.

func (*MockHistoryServiceServer) RebuildMutableState added in v1.16.0 

func (m *MockHistoryServiceServer) RebuildMutableState(arg0 context.Context, arg1 *historyservice.RebuildMutableStateRequest) (*historyservice.RebuildMutableStateResponse, error)

RebuildMutableState mocks base method.

func (*MockHistoryServiceServer) RecordActivityTaskHeartbeat 

func (m *MockHistoryServiceServer) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *historyservice.RecordActivityTaskHeartbeatRequest) (*historyservice.RecordActivityTaskHeartbeatResponse, error)

RecordActivityTaskHeartbeat mocks base method.

func (*MockHistoryServiceServer) RecordActivityTaskStarted 

func (m *MockHistoryServiceServer) RecordActivityTaskStarted(arg0 context.Context, arg1 *historyservice.RecordActivityTaskStartedRequest) (*historyservice.RecordActivityTaskStartedResponse, error)

RecordActivityTaskStarted mocks base method.

func (*MockHistoryServiceServer) RecordChildExecutionCompleted 

func (m *MockHistoryServiceServer) RecordChildExecutionCompleted(arg0 context.Context, arg1 *historyservice.RecordChildExecutionCompletedRequest) (*historyservice.RecordChildExecutionCompletedResponse, error)

RecordChildExecutionCompleted mocks base method.

func (*MockHistoryServiceServer) RecordWorkflowTaskStarted 

func (m *MockHistoryServiceServer) RecordWorkflowTaskStarted(arg0 context.Context, arg1 *historyservice.RecordWorkflowTaskStartedRequest) (*historyservice.RecordWorkflowTaskStartedResponse, error)

RecordWorkflowTaskStarted mocks base method.

func (*MockHistoryServiceServer) RefreshWorkflowTasks 

func (m *MockHistoryServiceServer) RefreshWorkflowTasks(arg0 context.Context, arg1 *historyservice.RefreshWorkflowTasksRequest) (*historyservice.RefreshWorkflowTasksResponse, error)

RefreshWorkflowTasks mocks base method.

func (*MockHistoryServiceServer) RemoveSignalMutableState 

func (m *MockHistoryServiceServer) RemoveSignalMutableState(arg0 context.Context, arg1 *historyservice.RemoveSignalMutableStateRequest) (*historyservice.RemoveSignalMutableStateResponse, error)

RemoveSignalMutableState mocks base method.

func (*MockHistoryServiceServer) RemoveTask 

func (m *MockHistoryServiceServer) RemoveTask(arg0 context.Context, arg1 *historyservice.RemoveTaskRequest) (*historyservice.RemoveTaskResponse, error)

RemoveTask mocks base method.

func (*MockHistoryServiceServer) ReplicateEventsV2 

func (m *MockHistoryServiceServer) ReplicateEventsV2(arg0 context.Context, arg1 *historyservice.ReplicateEventsV2Request) (*historyservice.ReplicateEventsV2Response, error)

ReplicateEventsV2 mocks base method.

func (*MockHistoryServiceServer) ReplicateWorkflowState added in v1.20.0 

func (m *MockHistoryServiceServer) ReplicateWorkflowState(arg0 context.Context, arg1 *historyservice.ReplicateWorkflowStateRequest) (*historyservice.ReplicateWorkflowStateResponse, error)

ReplicateWorkflowState mocks base method.

func (*MockHistoryServiceServer) RequestCancelWorkflowExecution 

func (m *MockHistoryServiceServer) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *historyservice.RequestCancelWorkflowExecutionRequest) (*historyservice.RequestCancelWorkflowExecutionResponse, error)

RequestCancelWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) ResetStickyTaskQueue 

func (m *MockHistoryServiceServer) ResetStickyTaskQueue(arg0 context.Context, arg1 *historyservice.ResetStickyTaskQueueRequest) (*historyservice.ResetStickyTaskQueueResponse, error)

ResetStickyTaskQueue mocks base method.

func (*MockHistoryServiceServer) ResetWorkflowExecution 

func (m *MockHistoryServiceServer) ResetWorkflowExecution(arg0 context.Context, arg1 *historyservice.ResetWorkflowExecutionRequest) (*historyservice.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) RespondActivityTaskCanceled 

func (m *MockHistoryServiceServer) RespondActivityTaskCanceled(arg0 context.Context, arg1 *historyservice.RespondActivityTaskCanceledRequest) (*historyservice.RespondActivityTaskCanceledResponse, error)

RespondActivityTaskCanceled mocks base method.

func (*MockHistoryServiceServer) RespondActivityTaskCompleted 

func (m *MockHistoryServiceServer) RespondActivityTaskCompleted(arg0 context.Context, arg1 *historyservice.RespondActivityTaskCompletedRequest) (*historyservice.RespondActivityTaskCompletedResponse, error)

RespondActivityTaskCompleted mocks base method.

func (*MockHistoryServiceServer) RespondActivityTaskFailed 

func (m *MockHistoryServiceServer) RespondActivityTaskFailed(arg0 context.Context, arg1 *historyservice.RespondActivityTaskFailedRequest) (*historyservice.RespondActivityTaskFailedResponse, error)

RespondActivityTaskFailed mocks base method.

func (*MockHistoryServiceServer) RespondWorkflowTaskCompleted 

func (m *MockHistoryServiceServer) RespondWorkflowTaskCompleted(arg0 context.Context, arg1 *historyservice.RespondWorkflowTaskCompletedRequest) (*historyservice.RespondWorkflowTaskCompletedResponse, error)

RespondWorkflowTaskCompleted mocks base method.

func (*MockHistoryServiceServer) RespondWorkflowTaskFailed 

func (m *MockHistoryServiceServer) RespondWorkflowTaskFailed(arg0 context.Context, arg1 *historyservice.RespondWorkflowTaskFailedRequest) (*historyservice.RespondWorkflowTaskFailedResponse, error)

RespondWorkflowTaskFailed mocks base method.

func (*MockHistoryServiceServer) ScheduleWorkflowTask 

func (m *MockHistoryServiceServer) ScheduleWorkflowTask(arg0 context.Context, arg1 *historyservice.ScheduleWorkflowTaskRequest) (*historyservice.ScheduleWorkflowTaskResponse, error)

ScheduleWorkflowTask mocks base method.

func (*MockHistoryServiceServer) SignalWithStartWorkflowExecution 

func (m *MockHistoryServiceServer) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *historyservice.SignalWithStartWorkflowExecutionRequest) (*historyservice.SignalWithStartWorkflowExecutionResponse, error)

SignalWithStartWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) SignalWorkflowExecution 

func (m *MockHistoryServiceServer) SignalWorkflowExecution(arg0 context.Context, arg1 *historyservice.SignalWorkflowExecutionRequest) (*historyservice.SignalWorkflowExecutionResponse, error)

SignalWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) StartWorkflowExecution 

func (m *MockHistoryServiceServer) StartWorkflowExecution(arg0 context.Context, arg1 *historyservice.StartWorkflowExecutionRequest) (*historyservice.StartWorkflowExecutionResponse, error)

StartWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) StreamWorkflowReplicationMessages added in v1.21.0 

func (m *MockHistoryServiceServer) StreamWorkflowReplicationMessages(arg0 historyservice.HistoryService_StreamWorkflowReplicationMessagesServer) error

StreamWorkflowReplicationMessages mocks base method.

func (*MockHistoryServiceServer) SyncActivity 

func (m *MockHistoryServiceServer) SyncActivity(arg0 context.Context, arg1 *historyservice.SyncActivityRequest) (*historyservice.SyncActivityResponse, error)

SyncActivity mocks base method.

func (*MockHistoryServiceServer) SyncShardStatus 

func (m *MockHistoryServiceServer) SyncShardStatus(arg0 context.Context, arg1 *historyservice.SyncShardStatusRequest) (*historyservice.SyncShardStatusResponse, error)

SyncShardStatus mocks base method.

func (*MockHistoryServiceServer) TerminateWorkflowExecution 

func (m *MockHistoryServiceServer) TerminateWorkflowExecution(arg0 context.Context, arg1 *historyservice.TerminateWorkflowExecutionRequest) (*historyservice.TerminateWorkflowExecutionResponse, error)

TerminateWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) UpdateWorkflowExecution added in v1.20.0 

func (m *MockHistoryServiceServer) UpdateWorkflowExecution(arg0 context.Context, arg1 *historyservice.UpdateWorkflowExecutionRequest) (*historyservice.UpdateWorkflowExecutionResponse, error)

UpdateWorkflowExecution mocks base method.

func (*MockHistoryServiceServer) VerifyChildExecutionCompletionRecorded added in v1.17.0 

func (m *MockHistoryServiceServer) VerifyChildExecutionCompletionRecorded(arg0 context.Context, arg1 *historyservice.VerifyChildExecutionCompletionRecordedRequest) (*historyservice.VerifyChildExecutionCompletionRecordedResponse, error)

VerifyChildExecutionCompletionRecorded mocks base method.

func (*MockHistoryServiceServer) VerifyFirstWorkflowTaskScheduled added in v1.17.0 

func (m *MockHistoryServiceServer) VerifyFirstWorkflowTaskScheduled(arg0 context.Context, arg1 *historyservice.VerifyFirstWorkflowTaskScheduledRequest) (*historyservice.VerifyFirstWorkflowTaskScheduledResponse, error)

VerifyFirstWorkflowTaskScheduled mocks base method.

type MockHistoryServiceServerMockRecorder 

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

MockHistoryServiceServerMockRecorder is the mock recorder for MockHistoryServiceServer.

func (*MockHistoryServiceServerMockRecorder) CloseShard 

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

CloseShard indicates an expected call of CloseShard.

func (*MockHistoryServiceServerMockRecorder) DeleteWorkflowExecution added in v1.15.0 

func (mr *MockHistoryServiceServerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) DeleteWorkflowVisibilityRecord added in v1.17.0 

func (mr *MockHistoryServiceServerMockRecorder) DeleteWorkflowVisibilityRecord(arg0, arg1 interface{}) *gomock.Call

DeleteWorkflowVisibilityRecord indicates an expected call of DeleteWorkflowVisibilityRecord.

func (*MockHistoryServiceServerMockRecorder) DescribeHistoryHost 

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

DescribeHistoryHost indicates an expected call of DescribeHistoryHost.

func (*MockHistoryServiceServerMockRecorder) DescribeMutableState 

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

DescribeMutableState indicates an expected call of DescribeMutableState.

func (*MockHistoryServiceServerMockRecorder) DescribeWorkflowExecution 

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

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) GenerateLastHistoryReplicationTasks added in v1.14.0 

func (mr *MockHistoryServiceServerMockRecorder) GenerateLastHistoryReplicationTasks(arg0, arg1 interface{}) *gomock.Call

GenerateLastHistoryReplicationTasks indicates an expected call of GenerateLastHistoryReplicationTasks.

func (*MockHistoryServiceServerMockRecorder) GetDLQMessages 

func (mr *MockHistoryServiceServerMockRecorder) GetDLQMessages(arg0, arg1 interface{}) *gomock.Call

GetDLQMessages indicates an expected call of GetDLQMessages.

func (*MockHistoryServiceServerMockRecorder) GetDLQReplicationMessages 

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

GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.

func (*MockHistoryServiceServerMockRecorder) GetMutableState 

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

GetMutableState indicates an expected call of GetMutableState.

func (*MockHistoryServiceServerMockRecorder) GetReplicationMessages 

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

GetReplicationMessages indicates an expected call of GetReplicationMessages.

func (*MockHistoryServiceServerMockRecorder) GetReplicationStatus added in v1.14.0 

func (mr *MockHistoryServiceServerMockRecorder) GetReplicationStatus(arg0, arg1 interface{}) *gomock.Call

GetReplicationStatus indicates an expected call of GetReplicationStatus.

func (*MockHistoryServiceServerMockRecorder) GetShard added in v1.14.0 

func (mr *MockHistoryServiceServerMockRecorder) GetShard(arg0, arg1 interface{}) *gomock.Call

GetShard indicates an expected call of GetShard.

func (*MockHistoryServiceServerMockRecorder) IsActivityTaskValid added in v1.22.0 

func (mr *MockHistoryServiceServerMockRecorder) IsActivityTaskValid(arg0, arg1 interface{}) *gomock.Call

IsActivityTaskValid indicates an expected call of IsActivityTaskValid.

func (*MockHistoryServiceServerMockRecorder) IsWorkflowTaskValid added in v1.22.0 

func (mr *MockHistoryServiceServerMockRecorder) IsWorkflowTaskValid(arg0, arg1 interface{}) *gomock.Call

IsWorkflowTaskValid indicates an expected call of IsWorkflowTaskValid.

func (*MockHistoryServiceServerMockRecorder) MergeDLQMessages 

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

MergeDLQMessages indicates an expected call of MergeDLQMessages.

func (*MockHistoryServiceServerMockRecorder) PollMutableState 

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

PollMutableState indicates an expected call of PollMutableState.

func (*MockHistoryServiceServerMockRecorder) PollWorkflowExecutionUpdate added in v1.21.0 

func (mr *MockHistoryServiceServerMockRecorder) PollWorkflowExecutionUpdate(arg0, arg1 interface{}) *gomock.Call

PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.

func (*MockHistoryServiceServerMockRecorder) PurgeDLQMessages 

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

PurgeDLQMessages indicates an expected call of PurgeDLQMessages.

func (*MockHistoryServiceServerMockRecorder) QueryWorkflow 

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

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockHistoryServiceServerMockRecorder) ReapplyEvents 

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

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockHistoryServiceServerMockRecorder) RebuildMutableState added in v1.16.0 

func (mr *MockHistoryServiceServerMockRecorder) RebuildMutableState(arg0, arg1 interface{}) *gomock.Call

RebuildMutableState indicates an expected call of RebuildMutableState.

func (*MockHistoryServiceServerMockRecorder) RecordActivityTaskHeartbeat 

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

RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.

func (*MockHistoryServiceServerMockRecorder) RecordActivityTaskStarted 

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

RecordActivityTaskStarted indicates an expected call of RecordActivityTaskStarted.

func (*MockHistoryServiceServerMockRecorder) RecordChildExecutionCompleted 

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

RecordChildExecutionCompleted indicates an expected call of RecordChildExecutionCompleted.

func (*MockHistoryServiceServerMockRecorder) RecordWorkflowTaskStarted 

func (mr *MockHistoryServiceServerMockRecorder) RecordWorkflowTaskStarted(arg0, arg1 interface{}) *gomock.Call

RecordWorkflowTaskStarted indicates an expected call of RecordWorkflowTaskStarted.

func (*MockHistoryServiceServerMockRecorder) RefreshWorkflowTasks 

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

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockHistoryServiceServerMockRecorder) RemoveSignalMutableState 

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

RemoveSignalMutableState indicates an expected call of RemoveSignalMutableState.

func (*MockHistoryServiceServerMockRecorder) RemoveTask 

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

RemoveTask indicates an expected call of RemoveTask.

func (*MockHistoryServiceServerMockRecorder) ReplicateEventsV2 

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

ReplicateEventsV2 indicates an expected call of ReplicateEventsV2.

func (*MockHistoryServiceServerMockRecorder) ReplicateWorkflowState added in v1.20.0 

func (mr *MockHistoryServiceServerMockRecorder) ReplicateWorkflowState(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowState indicates an expected call of ReplicateWorkflowState.

func (*MockHistoryServiceServerMockRecorder) RequestCancelWorkflowExecution 

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

RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) ResetStickyTaskQueue 

func (mr *MockHistoryServiceServerMockRecorder) ResetStickyTaskQueue(arg0, arg1 interface{}) *gomock.Call

ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.

func (*MockHistoryServiceServerMockRecorder) ResetWorkflowExecution 

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

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) RespondActivityTaskCanceled 

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

RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.

func (*MockHistoryServiceServerMockRecorder) RespondActivityTaskCompleted 

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

RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.

func (*MockHistoryServiceServerMockRecorder) RespondActivityTaskFailed 

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

RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.

func (*MockHistoryServiceServerMockRecorder) RespondWorkflowTaskCompleted 

func (mr *MockHistoryServiceServerMockRecorder) RespondWorkflowTaskCompleted(arg0, arg1 interface{}) *gomock.Call

RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.

func (*MockHistoryServiceServerMockRecorder) RespondWorkflowTaskFailed 

func (mr *MockHistoryServiceServerMockRecorder) RespondWorkflowTaskFailed(arg0, arg1 interface{}) *gomock.Call

RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.

func (*MockHistoryServiceServerMockRecorder) ScheduleWorkflowTask 

func (mr *MockHistoryServiceServerMockRecorder) ScheduleWorkflowTask(arg0, arg1 interface{}) *gomock.Call

ScheduleWorkflowTask indicates an expected call of ScheduleWorkflowTask.

func (*MockHistoryServiceServerMockRecorder) SignalWithStartWorkflowExecution 

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

SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) SignalWorkflowExecution 

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

SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) StartWorkflowExecution 

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

StartWorkflowExecution indicates an expected call of StartWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) StreamWorkflowReplicationMessages added in v1.21.0 

func (mr *MockHistoryServiceServerMockRecorder) StreamWorkflowReplicationMessages(arg0 interface{}) *gomock.Call

StreamWorkflowReplicationMessages indicates an expected call of StreamWorkflowReplicationMessages.

func (*MockHistoryServiceServerMockRecorder) SyncActivity 

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

SyncActivity indicates an expected call of SyncActivity.

func (*MockHistoryServiceServerMockRecorder) SyncShardStatus 

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

SyncShardStatus indicates an expected call of SyncShardStatus.

func (*MockHistoryServiceServerMockRecorder) TerminateWorkflowExecution 

func (mr *MockHistoryServiceServerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) UpdateWorkflowExecution added in v1.20.0 

func (mr *MockHistoryServiceServerMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

func (*MockHistoryServiceServerMockRecorder) VerifyChildExecutionCompletionRecorded added in v1.17.0 

func (mr *MockHistoryServiceServerMockRecorder) VerifyChildExecutionCompletionRecorded(arg0, arg1 interface{}) *gomock.Call

VerifyChildExecutionCompletionRecorded indicates an expected call of VerifyChildExecutionCompletionRecorded.

func (*MockHistoryServiceServerMockRecorder) VerifyFirstWorkflowTaskScheduled added in v1.17.0 

func (mr *MockHistoryServiceServerMockRecorder) VerifyFirstWorkflowTaskScheduled(arg0, arg1 interface{}) *gomock.Call

VerifyFirstWorkflowTaskScheduled indicates an expected call of VerifyFirstWorkflowTaskScheduled.

type MockHistoryService_StreamWorkflowReplicationMessagesClient added in v1.21.0 

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

MockHistoryService_StreamWorkflowReplicationMessagesClient is a mock of HistoryService_StreamWorkflowReplicationMessagesClient interface.

func NewMockHistoryService_StreamWorkflowReplicationMessagesClient added in v1.21.0 

func NewMockHistoryService_StreamWorkflowReplicationMessagesClient(ctrl *gomock.Controller) *MockHistoryService_StreamWorkflowReplicationMessagesClient

NewMockHistoryService_StreamWorkflowReplicationMessagesClient creates a new mock instance.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) CloseSend added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) CloseSend() error

CloseSend mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) Context added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) Context() context.Context

Context mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) EXPECT added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) EXPECT() *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder

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

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) Header added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) Recv added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) Recv() (*historyservice.StreamWorkflowReplicationMessagesResponse, error)

Recv mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) RecvMsg added in v1.21.0 

func (m_2 *MockHistoryService_StreamWorkflowReplicationMessagesClient) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) Send added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) Send(arg0 *historyservice.StreamWorkflowReplicationMessagesRequest) error

Send mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) SendMsg added in v1.21.0 

func (m_2 *MockHistoryService_StreamWorkflowReplicationMessagesClient) SendMsg(m any) error

SendMsg mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClient) Trailer added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesClient) Trailer() metadata.MD

Trailer mocks base method.

type MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder added in v1.21.0 

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

MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder is the mock recorder for MockHistoryService_StreamWorkflowReplicationMessagesClient.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) CloseSend added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Context added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Header added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Recv added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) RecvMsg added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Send added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) SendMsg added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Trailer added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockHistoryService_StreamWorkflowReplicationMessagesServer added in v1.21.0 

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

MockHistoryService_StreamWorkflowReplicationMessagesServer is a mock of HistoryService_StreamWorkflowReplicationMessagesServer interface.

func NewMockHistoryService_StreamWorkflowReplicationMessagesServer added in v1.21.0 

func NewMockHistoryService_StreamWorkflowReplicationMessagesServer(ctrl *gomock.Controller) *MockHistoryService_StreamWorkflowReplicationMessagesServer

NewMockHistoryService_StreamWorkflowReplicationMessagesServer creates a new mock instance.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) Context added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) Context() context.Context

Context mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) EXPECT added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) EXPECT() *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder

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

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) Recv added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) Recv() (*historyservice.StreamWorkflowReplicationMessagesRequest, error)

Recv mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) RecvMsg added in v1.21.0 

func (m_2 *MockHistoryService_StreamWorkflowReplicationMessagesServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) Send added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) Send(arg0 *historyservice.StreamWorkflowReplicationMessagesResponse) error

Send mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) SendHeader added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) SendMsg added in v1.21.0 

func (m_2 *MockHistoryService_StreamWorkflowReplicationMessagesServer) SendMsg(m any) error

SendMsg mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) SetHeader added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServer) SetTrailer added in v1.21.0 

func (m *MockHistoryService_StreamWorkflowReplicationMessagesServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder added in v1.21.0 

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

MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder is the mock recorder for MockHistoryService_StreamWorkflowReplicationMessagesServer.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Context added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Recv added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) RecvMsg added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Send added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SendHeader added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SendMsg added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SetHeader added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SetTrailer added in v1.21.0 

func (mr *MockHistoryService_StreamWorkflowReplicationMessagesServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.