Documentation ¶
Overview ¶
Package adminservicemock is a generated GoMock package.
Index ¶
- type MockAdminServiceClient
- func (m *MockAdminServiceClient) AddSearchAttribute(ctx context.Context, in *adminservice.AddSearchAttributeRequest, ...) (*adminservice.AddSearchAttributeResponse, error)
- func (m *MockAdminServiceClient) CloseShard(ctx context.Context, in *adminservice.CloseShardRequest, ...) (*adminservice.CloseShardResponse, error)
- func (m *MockAdminServiceClient) DescribeCluster(ctx context.Context, in *adminservice.DescribeClusterRequest, ...) (*adminservice.DescribeClusterResponse, error)
- func (m *MockAdminServiceClient) DescribeHistoryHost(ctx context.Context, in *adminservice.DescribeHistoryHostRequest, ...) (*adminservice.DescribeHistoryHostResponse, error)
- func (m *MockAdminServiceClient) DescribeWorkflowExecution(ctx context.Context, in *adminservice.DescribeWorkflowExecutionRequest, ...) (*adminservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockAdminServiceClient) EXPECT() *MockAdminServiceClientMockRecorder
- func (m *MockAdminServiceClient) GetDLQMessages(ctx context.Context, in *adminservice.GetDLQMessagesRequest, ...) (*adminservice.GetDLQMessagesResponse, error)
- func (m *MockAdminServiceClient) GetDLQReplicationMessages(ctx context.Context, in *adminservice.GetDLQReplicationMessagesRequest, ...) (*adminservice.GetDLQReplicationMessagesResponse, error)
- func (m *MockAdminServiceClient) GetNamespaceReplicationMessages(ctx context.Context, in *adminservice.GetNamespaceReplicationMessagesRequest, ...) (*adminservice.GetNamespaceReplicationMessagesResponse, error)
- func (m *MockAdminServiceClient) GetReplicationMessages(ctx context.Context, in *adminservice.GetReplicationMessagesRequest, ...) (*adminservice.GetReplicationMessagesResponse, error)
- func (m *MockAdminServiceClient) GetWorkflowExecutionRawHistoryV2(ctx context.Context, in *adminservice.GetWorkflowExecutionRawHistoryV2Request, ...) (*adminservice.GetWorkflowExecutionRawHistoryV2Response, error)
- func (m *MockAdminServiceClient) MergeDLQMessages(ctx context.Context, in *adminservice.MergeDLQMessagesRequest, ...) (*adminservice.MergeDLQMessagesResponse, error)
- func (m *MockAdminServiceClient) PurgeDLQMessages(ctx context.Context, in *adminservice.PurgeDLQMessagesRequest, ...) (*adminservice.PurgeDLQMessagesResponse, error)
- func (m *MockAdminServiceClient) ReapplyEvents(ctx context.Context, in *adminservice.ReapplyEventsRequest, ...) (*adminservice.ReapplyEventsResponse, error)
- func (m *MockAdminServiceClient) RefreshWorkflowTasks(ctx context.Context, in *adminservice.RefreshWorkflowTasksRequest, ...) (*adminservice.RefreshWorkflowTasksResponse, error)
- func (m *MockAdminServiceClient) RemoveTask(ctx context.Context, in *adminservice.RemoveTaskRequest, ...) (*adminservice.RemoveTaskResponse, error)
- func (m *MockAdminServiceClient) ResendReplicationTasks(ctx context.Context, in *adminservice.ResendReplicationTasksRequest, ...) (*adminservice.ResendReplicationTasksResponse, error)
- type MockAdminServiceClientMockRecorder
- func (mr *MockAdminServiceClientMockRecorder) AddSearchAttribute(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) CloseShard(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) DescribeCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) DescribeHistoryHost(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) DescribeWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) GetDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) GetDLQReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) GetNamespaceReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) GetReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) MergeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) PurgeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) ReapplyEvents(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) RefreshWorkflowTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) RemoveTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAdminServiceClientMockRecorder) ResendReplicationTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockAdminServiceServer
- func (m *MockAdminServiceServer) AddSearchAttribute(arg0 context.Context, arg1 *adminservice.AddSearchAttributeRequest) (*adminservice.AddSearchAttributeResponse, error)
- func (m *MockAdminServiceServer) CloseShard(arg0 context.Context, arg1 *adminservice.CloseShardRequest) (*adminservice.CloseShardResponse, error)
- func (m *MockAdminServiceServer) DescribeCluster(arg0 context.Context, arg1 *adminservice.DescribeClusterRequest) (*adminservice.DescribeClusterResponse, error)
- func (m *MockAdminServiceServer) DescribeHistoryHost(arg0 context.Context, arg1 *adminservice.DescribeHistoryHostRequest) (*adminservice.DescribeHistoryHostResponse, error)
- func (m *MockAdminServiceServer) DescribeWorkflowExecution(arg0 context.Context, arg1 *adminservice.DescribeWorkflowExecutionRequest) (*adminservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockAdminServiceServer) EXPECT() *MockAdminServiceServerMockRecorder
- func (m *MockAdminServiceServer) GetDLQMessages(arg0 context.Context, arg1 *adminservice.GetDLQMessagesRequest) (*adminservice.GetDLQMessagesResponse, error)
- func (m *MockAdminServiceServer) GetDLQReplicationMessages(arg0 context.Context, arg1 *adminservice.GetDLQReplicationMessagesRequest) (*adminservice.GetDLQReplicationMessagesResponse, error)
- func (m *MockAdminServiceServer) GetNamespaceReplicationMessages(arg0 context.Context, ...) (*adminservice.GetNamespaceReplicationMessagesResponse, error)
- func (m *MockAdminServiceServer) GetReplicationMessages(arg0 context.Context, arg1 *adminservice.GetReplicationMessagesRequest) (*adminservice.GetReplicationMessagesResponse, error)
- func (m *MockAdminServiceServer) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, ...) (*adminservice.GetWorkflowExecutionRawHistoryV2Response, error)
- func (m *MockAdminServiceServer) MergeDLQMessages(arg0 context.Context, arg1 *adminservice.MergeDLQMessagesRequest) (*adminservice.MergeDLQMessagesResponse, error)
- func (m *MockAdminServiceServer) PurgeDLQMessages(arg0 context.Context, arg1 *adminservice.PurgeDLQMessagesRequest) (*adminservice.PurgeDLQMessagesResponse, error)
- func (m *MockAdminServiceServer) ReapplyEvents(arg0 context.Context, arg1 *adminservice.ReapplyEventsRequest) (*adminservice.ReapplyEventsResponse, error)
- func (m *MockAdminServiceServer) RefreshWorkflowTasks(arg0 context.Context, arg1 *adminservice.RefreshWorkflowTasksRequest) (*adminservice.RefreshWorkflowTasksResponse, error)
- func (m *MockAdminServiceServer) RemoveTask(arg0 context.Context, arg1 *adminservice.RemoveTaskRequest) (*adminservice.RemoveTaskResponse, error)
- func (m *MockAdminServiceServer) ResendReplicationTasks(arg0 context.Context, arg1 *adminservice.ResendReplicationTasksRequest) (*adminservice.ResendReplicationTasksResponse, error)
- type MockAdminServiceServerMockRecorder
- func (mr *MockAdminServiceServerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) DescribeCluster(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) GetDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) GetNamespaceReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAdminServiceServerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAdminServiceClient ¶
type MockAdminServiceClient struct {
// contains filtered or unexported fields
}
MockAdminServiceClient is a mock of AdminServiceClient interface.
func NewMockAdminServiceClient ¶
func NewMockAdminServiceClient(ctrl *gomock.Controller) *MockAdminServiceClient
NewMockAdminServiceClient creates a new mock instance.
func (*MockAdminServiceClient) AddSearchAttribute ¶
func (m *MockAdminServiceClient) AddSearchAttribute(ctx context.Context, in *adminservice.AddSearchAttributeRequest, opts ...grpc.CallOption) (*adminservice.AddSearchAttributeResponse, error)
AddSearchAttribute mocks base method.
func (*MockAdminServiceClient) CloseShard ¶
func (m *MockAdminServiceClient) CloseShard(ctx context.Context, in *adminservice.CloseShardRequest, opts ...grpc.CallOption) (*adminservice.CloseShardResponse, error)
CloseShard mocks base method.
func (*MockAdminServiceClient) DescribeCluster ¶
func (m *MockAdminServiceClient) DescribeCluster(ctx context.Context, in *adminservice.DescribeClusterRequest, opts ...grpc.CallOption) (*adminservice.DescribeClusterResponse, error)
DescribeCluster mocks base method.
func (*MockAdminServiceClient) DescribeHistoryHost ¶
func (m *MockAdminServiceClient) DescribeHistoryHost(ctx context.Context, in *adminservice.DescribeHistoryHostRequest, opts ...grpc.CallOption) (*adminservice.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method.
func (*MockAdminServiceClient) DescribeWorkflowExecution ¶
func (m *MockAdminServiceClient) DescribeWorkflowExecution(ctx context.Context, in *adminservice.DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*adminservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockAdminServiceClient) EXPECT ¶
func (m *MockAdminServiceClient) EXPECT() *MockAdminServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAdminServiceClient) GetDLQMessages ¶
func (m *MockAdminServiceClient) GetDLQMessages(ctx context.Context, in *adminservice.GetDLQMessagesRequest, opts ...grpc.CallOption) (*adminservice.GetDLQMessagesResponse, error)
GetDLQMessages mocks base method.
func (*MockAdminServiceClient) GetDLQReplicationMessages ¶
func (m *MockAdminServiceClient) GetDLQReplicationMessages(ctx context.Context, in *adminservice.GetDLQReplicationMessagesRequest, opts ...grpc.CallOption) (*adminservice.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method.
func (*MockAdminServiceClient) GetNamespaceReplicationMessages ¶
func (m *MockAdminServiceClient) GetNamespaceReplicationMessages(ctx context.Context, in *adminservice.GetNamespaceReplicationMessagesRequest, opts ...grpc.CallOption) (*adminservice.GetNamespaceReplicationMessagesResponse, error)
GetNamespaceReplicationMessages mocks base method.
func (*MockAdminServiceClient) GetReplicationMessages ¶
func (m *MockAdminServiceClient) GetReplicationMessages(ctx context.Context, in *adminservice.GetReplicationMessagesRequest, opts ...grpc.CallOption) (*adminservice.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method.
func (*MockAdminServiceClient) GetWorkflowExecutionRawHistoryV2 ¶
func (m *MockAdminServiceClient) GetWorkflowExecutionRawHistoryV2(ctx context.Context, in *adminservice.GetWorkflowExecutionRawHistoryV2Request, opts ...grpc.CallOption) (*adminservice.GetWorkflowExecutionRawHistoryV2Response, error)
GetWorkflowExecutionRawHistoryV2 mocks base method.
func (*MockAdminServiceClient) MergeDLQMessages ¶
func (m *MockAdminServiceClient) MergeDLQMessages(ctx context.Context, in *adminservice.MergeDLQMessagesRequest, opts ...grpc.CallOption) (*adminservice.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method.
func (*MockAdminServiceClient) PurgeDLQMessages ¶
func (m *MockAdminServiceClient) PurgeDLQMessages(ctx context.Context, in *adminservice.PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*adminservice.PurgeDLQMessagesResponse, error)
PurgeDLQMessages mocks base method.
func (*MockAdminServiceClient) ReapplyEvents ¶
func (m *MockAdminServiceClient) ReapplyEvents(ctx context.Context, in *adminservice.ReapplyEventsRequest, opts ...grpc.CallOption) (*adminservice.ReapplyEventsResponse, error)
ReapplyEvents mocks base method.
func (*MockAdminServiceClient) RefreshWorkflowTasks ¶
func (m *MockAdminServiceClient) RefreshWorkflowTasks(ctx context.Context, in *adminservice.RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*adminservice.RefreshWorkflowTasksResponse, error)
RefreshWorkflowTasks mocks base method.
func (*MockAdminServiceClient) RemoveTask ¶
func (m *MockAdminServiceClient) RemoveTask(ctx context.Context, in *adminservice.RemoveTaskRequest, opts ...grpc.CallOption) (*adminservice.RemoveTaskResponse, error)
RemoveTask mocks base method.
func (*MockAdminServiceClient) ResendReplicationTasks ¶
func (m *MockAdminServiceClient) ResendReplicationTasks(ctx context.Context, in *adminservice.ResendReplicationTasksRequest, opts ...grpc.CallOption) (*adminservice.ResendReplicationTasksResponse, error)
ResendReplicationTasks mocks base method.
type MockAdminServiceClientMockRecorder ¶
type MockAdminServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAdminServiceClientMockRecorder is the mock recorder for MockAdminServiceClient.
func (*MockAdminServiceClientMockRecorder) AddSearchAttribute ¶
func (mr *MockAdminServiceClientMockRecorder) AddSearchAttribute(ctx, in interface{}, opts ...interface{}) *gomock.Call
AddSearchAttribute indicates an expected call of AddSearchAttribute.
func (*MockAdminServiceClientMockRecorder) CloseShard ¶
func (mr *MockAdminServiceClientMockRecorder) CloseShard(ctx, in interface{}, opts ...interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard.
func (*MockAdminServiceClientMockRecorder) DescribeCluster ¶
func (mr *MockAdminServiceClientMockRecorder) DescribeCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeCluster indicates an expected call of DescribeCluster.
func (*MockAdminServiceClientMockRecorder) DescribeHistoryHost ¶
func (mr *MockAdminServiceClientMockRecorder) DescribeHistoryHost(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost.
func (*MockAdminServiceClientMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockAdminServiceClientMockRecorder) DescribeWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockAdminServiceClientMockRecorder) GetDLQMessages ¶
func (mr *MockAdminServiceClientMockRecorder) GetDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetDLQMessages indicates an expected call of GetDLQMessages.
func (*MockAdminServiceClientMockRecorder) GetDLQReplicationMessages ¶
func (mr *MockAdminServiceClientMockRecorder) GetDLQReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockAdminServiceClientMockRecorder) GetNamespaceReplicationMessages ¶
func (mr *MockAdminServiceClientMockRecorder) GetNamespaceReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetNamespaceReplicationMessages indicates an expected call of GetNamespaceReplicationMessages.
func (*MockAdminServiceClientMockRecorder) GetReplicationMessages ¶
func (mr *MockAdminServiceClientMockRecorder) GetReplicationMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockAdminServiceClientMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶
func (mr *MockAdminServiceClientMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.
func (*MockAdminServiceClientMockRecorder) MergeDLQMessages ¶
func (mr *MockAdminServiceClientMockRecorder) MergeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockAdminServiceClientMockRecorder) PurgeDLQMessages ¶
func (mr *MockAdminServiceClientMockRecorder) PurgeDLQMessages(ctx, in interface{}, opts ...interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockAdminServiceClientMockRecorder) ReapplyEvents ¶
func (mr *MockAdminServiceClientMockRecorder) ReapplyEvents(ctx, in interface{}, opts ...interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockAdminServiceClientMockRecorder) RefreshWorkflowTasks ¶
func (mr *MockAdminServiceClientMockRecorder) RefreshWorkflowTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockAdminServiceClientMockRecorder) RemoveTask ¶
func (mr *MockAdminServiceClientMockRecorder) RemoveTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask.
func (*MockAdminServiceClientMockRecorder) ResendReplicationTasks ¶
func (mr *MockAdminServiceClientMockRecorder) ResendReplicationTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
ResendReplicationTasks indicates an expected call of ResendReplicationTasks.
type MockAdminServiceServer ¶
type MockAdminServiceServer struct {
// contains filtered or unexported fields
}
MockAdminServiceServer is a mock of AdminServiceServer interface.
func NewMockAdminServiceServer ¶
func NewMockAdminServiceServer(ctrl *gomock.Controller) *MockAdminServiceServer
NewMockAdminServiceServer creates a new mock instance.
func (*MockAdminServiceServer) AddSearchAttribute ¶
func (m *MockAdminServiceServer) AddSearchAttribute(arg0 context.Context, arg1 *adminservice.AddSearchAttributeRequest) (*adminservice.AddSearchAttributeResponse, error)
AddSearchAttribute mocks base method.
func (*MockAdminServiceServer) CloseShard ¶
func (m *MockAdminServiceServer) CloseShard(arg0 context.Context, arg1 *adminservice.CloseShardRequest) (*adminservice.CloseShardResponse, error)
CloseShard mocks base method.
func (*MockAdminServiceServer) DescribeCluster ¶
func (m *MockAdminServiceServer) DescribeCluster(arg0 context.Context, arg1 *adminservice.DescribeClusterRequest) (*adminservice.DescribeClusterResponse, error)
DescribeCluster mocks base method.
func (*MockAdminServiceServer) DescribeHistoryHost ¶
func (m *MockAdminServiceServer) DescribeHistoryHost(arg0 context.Context, arg1 *adminservice.DescribeHistoryHostRequest) (*adminservice.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method.
func (*MockAdminServiceServer) DescribeWorkflowExecution ¶
func (m *MockAdminServiceServer) DescribeWorkflowExecution(arg0 context.Context, arg1 *adminservice.DescribeWorkflowExecutionRequest) (*adminservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockAdminServiceServer) EXPECT ¶
func (m *MockAdminServiceServer) EXPECT() *MockAdminServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAdminServiceServer) GetDLQMessages ¶
func (m *MockAdminServiceServer) GetDLQMessages(arg0 context.Context, arg1 *adminservice.GetDLQMessagesRequest) (*adminservice.GetDLQMessagesResponse, error)
GetDLQMessages mocks base method.
func (*MockAdminServiceServer) GetDLQReplicationMessages ¶
func (m *MockAdminServiceServer) GetDLQReplicationMessages(arg0 context.Context, arg1 *adminservice.GetDLQReplicationMessagesRequest) (*adminservice.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method.
func (*MockAdminServiceServer) GetNamespaceReplicationMessages ¶
func (m *MockAdminServiceServer) GetNamespaceReplicationMessages(arg0 context.Context, arg1 *adminservice.GetNamespaceReplicationMessagesRequest) (*adminservice.GetNamespaceReplicationMessagesResponse, error)
GetNamespaceReplicationMessages mocks base method.
func (*MockAdminServiceServer) GetReplicationMessages ¶
func (m *MockAdminServiceServer) GetReplicationMessages(arg0 context.Context, arg1 *adminservice.GetReplicationMessagesRequest) (*adminservice.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method.
func (*MockAdminServiceServer) GetWorkflowExecutionRawHistoryV2 ¶
func (m *MockAdminServiceServer) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *adminservice.GetWorkflowExecutionRawHistoryV2Request) (*adminservice.GetWorkflowExecutionRawHistoryV2Response, error)
GetWorkflowExecutionRawHistoryV2 mocks base method.
func (*MockAdminServiceServer) MergeDLQMessages ¶
func (m *MockAdminServiceServer) MergeDLQMessages(arg0 context.Context, arg1 *adminservice.MergeDLQMessagesRequest) (*adminservice.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method.
func (*MockAdminServiceServer) PurgeDLQMessages ¶
func (m *MockAdminServiceServer) PurgeDLQMessages(arg0 context.Context, arg1 *adminservice.PurgeDLQMessagesRequest) (*adminservice.PurgeDLQMessagesResponse, error)
PurgeDLQMessages mocks base method.
func (*MockAdminServiceServer) ReapplyEvents ¶
func (m *MockAdminServiceServer) ReapplyEvents(arg0 context.Context, arg1 *adminservice.ReapplyEventsRequest) (*adminservice.ReapplyEventsResponse, error)
ReapplyEvents mocks base method.
func (*MockAdminServiceServer) RefreshWorkflowTasks ¶
func (m *MockAdminServiceServer) RefreshWorkflowTasks(arg0 context.Context, arg1 *adminservice.RefreshWorkflowTasksRequest) (*adminservice.RefreshWorkflowTasksResponse, error)
RefreshWorkflowTasks mocks base method.
func (*MockAdminServiceServer) RemoveTask ¶
func (m *MockAdminServiceServer) RemoveTask(arg0 context.Context, arg1 *adminservice.RemoveTaskRequest) (*adminservice.RemoveTaskResponse, error)
RemoveTask mocks base method.
func (*MockAdminServiceServer) ResendReplicationTasks ¶
func (m *MockAdminServiceServer) ResendReplicationTasks(arg0 context.Context, arg1 *adminservice.ResendReplicationTasksRequest) (*adminservice.ResendReplicationTasksResponse, error)
ResendReplicationTasks mocks base method.
type MockAdminServiceServerMockRecorder ¶
type MockAdminServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockAdminServiceServerMockRecorder is the mock recorder for MockAdminServiceServer.
func (*MockAdminServiceServerMockRecorder) AddSearchAttribute ¶
func (mr *MockAdminServiceServerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
AddSearchAttribute indicates an expected call of AddSearchAttribute.
func (*MockAdminServiceServerMockRecorder) CloseShard ¶
func (mr *MockAdminServiceServerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard.
func (*MockAdminServiceServerMockRecorder) DescribeCluster ¶
func (mr *MockAdminServiceServerMockRecorder) DescribeCluster(arg0, arg1 interface{}) *gomock.Call
DescribeCluster indicates an expected call of DescribeCluster.
func (*MockAdminServiceServerMockRecorder) DescribeHistoryHost ¶
func (mr *MockAdminServiceServerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost.
func (*MockAdminServiceServerMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockAdminServiceServerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockAdminServiceServerMockRecorder) GetDLQMessages ¶
func (mr *MockAdminServiceServerMockRecorder) GetDLQMessages(arg0, arg1 interface{}) *gomock.Call
GetDLQMessages indicates an expected call of GetDLQMessages.
func (*MockAdminServiceServerMockRecorder) GetDLQReplicationMessages ¶
func (mr *MockAdminServiceServerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockAdminServiceServerMockRecorder) GetNamespaceReplicationMessages ¶
func (mr *MockAdminServiceServerMockRecorder) GetNamespaceReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetNamespaceReplicationMessages indicates an expected call of GetNamespaceReplicationMessages.
func (*MockAdminServiceServerMockRecorder) GetReplicationMessages ¶
func (mr *MockAdminServiceServerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockAdminServiceServerMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶
func (mr *MockAdminServiceServerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.
func (*MockAdminServiceServerMockRecorder) MergeDLQMessages ¶
func (mr *MockAdminServiceServerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockAdminServiceServerMockRecorder) PurgeDLQMessages ¶
func (mr *MockAdminServiceServerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockAdminServiceServerMockRecorder) ReapplyEvents ¶
func (mr *MockAdminServiceServerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockAdminServiceServerMockRecorder) RefreshWorkflowTasks ¶
func (mr *MockAdminServiceServerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockAdminServiceServerMockRecorder) RemoveTask ¶
func (mr *MockAdminServiceServerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask.
func (*MockAdminServiceServerMockRecorder) ResendReplicationTasks ¶
func (mr *MockAdminServiceServerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
ResendReplicationTasks indicates an expected call of ResendReplicationTasks.