adminservicemock

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package adminservicemock is a generated GoMock package.

Index

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) AddOrUpdateRemoteCluster added in v1.14.0 

func (m *MockAdminServiceClient) AddOrUpdateRemoteCluster(ctx context.Context, in *adminservice.AddOrUpdateRemoteClusterRequest, opts ...grpc.CallOption) (*adminservice.AddOrUpdateRemoteClusterResponse, error)

AddOrUpdateRemoteCluster mocks base method.

func (*MockAdminServiceClient) AddSearchAttributes added in v1.10.0 

func (m *MockAdminServiceClient) AddSearchAttributes(ctx context.Context, in *adminservice.AddSearchAttributesRequest, opts ...grpc.CallOption) (*adminservice.AddSearchAttributesResponse, error)

AddSearchAttributes 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) DeleteWorkflowExecution added in v1.17.0 

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

DeleteWorkflowExecution 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) DescribeMutableState added in v1.3.0 

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

DescribeMutableState 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) GetSearchAttributes added in v1.10.0 

func (m *MockAdminServiceClient) GetSearchAttributes(ctx context.Context, in *adminservice.GetSearchAttributesRequest, opts ...grpc.CallOption) (*adminservice.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockAdminServiceClient) GetShard added in v1.14.0 

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

GetShard mocks base method.

func (*MockAdminServiceClient) GetTaskQueueTasks added in v1.14.0 

func (m *MockAdminServiceClient) GetTaskQueueTasks(ctx context.Context, in *adminservice.GetTaskQueueTasksRequest, opts ...grpc.CallOption) (*adminservice.GetTaskQueueTasksResponse, error)

GetTaskQueueTasks 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) ListClusterMembers added in v1.14.0 

func (m *MockAdminServiceClient) ListClusterMembers(ctx context.Context, in *adminservice.ListClusterMembersRequest, opts ...grpc.CallOption) (*adminservice.ListClusterMembersResponse, error)

ListClusterMembers mocks base method.

func (*MockAdminServiceClient) ListClusters added in v1.15.0 

func (m *MockAdminServiceClient) ListClusters(ctx context.Context, in *adminservice.ListClustersRequest, opts ...grpc.CallOption) (*adminservice.ListClustersResponse, error)

ListClusters mocks base method.

func (*MockAdminServiceClient) ListHistoryTasks added in v1.16.0 

func (m *MockAdminServiceClient) ListHistoryTasks(ctx context.Context, in *adminservice.ListHistoryTasksRequest, opts ...grpc.CallOption) (*adminservice.ListHistoryTasksResponse, error)

ListHistoryTasks 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) RebuildMutableState added in v1.16.0 

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

RebuildMutableState 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) RemoveRemoteCluster added in v1.14.0 

func (m *MockAdminServiceClient) RemoveRemoteCluster(ctx context.Context, in *adminservice.RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*adminservice.RemoveRemoteClusterResponse, error)

RemoveRemoteCluster mocks base method.

func (*MockAdminServiceClient) RemoveSearchAttributes added in v1.11.0 

func (m *MockAdminServiceClient) RemoveSearchAttributes(ctx context.Context, in *adminservice.RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*adminservice.RemoveSearchAttributesResponse, error)

RemoveSearchAttributes 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) AddOrUpdateRemoteCluster added in v1.14.0 

func (mr *MockAdminServiceClientMockRecorder) AddOrUpdateRemoteCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddOrUpdateRemoteCluster indicates an expected call of AddOrUpdateRemoteCluster.

func (*MockAdminServiceClientMockRecorder) AddSearchAttributes added in v1.10.0 

func (mr *MockAdminServiceClientMockRecorder) AddSearchAttributes(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddSearchAttributes indicates an expected call of AddSearchAttributes.

func (*MockAdminServiceClientMockRecorder) CloseShard 

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

CloseShard indicates an expected call of CloseShard.

func (*MockAdminServiceClientMockRecorder) DeleteWorkflowExecution added in v1.17.0 

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

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

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) DescribeMutableState added in v1.3.0 

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

DescribeMutableState indicates an expected call of DescribeMutableState.

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) GetSearchAttributes added in v1.10.0 

func (mr *MockAdminServiceClientMockRecorder) GetSearchAttributes(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockAdminServiceClientMockRecorder) GetShard added in v1.14.0 

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

GetShard indicates an expected call of GetShard.

func (*MockAdminServiceClientMockRecorder) GetTaskQueueTasks added in v1.14.0 

func (mr *MockAdminServiceClientMockRecorder) GetTaskQueueTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetTaskQueueTasks indicates an expected call of GetTaskQueueTasks.

func (*MockAdminServiceClientMockRecorder) GetWorkflowExecutionRawHistoryV2 

func (mr *MockAdminServiceClientMockRecorder) GetWorkflowExecutionRawHistoryV2(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.

func (*MockAdminServiceClientMockRecorder) ListClusterMembers added in v1.14.0 

func (mr *MockAdminServiceClientMockRecorder) ListClusterMembers(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListClusterMembers indicates an expected call of ListClusterMembers.

func (*MockAdminServiceClientMockRecorder) ListClusters added in v1.15.0 

func (mr *MockAdminServiceClientMockRecorder) ListClusters(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListClusters indicates an expected call of ListClusters.

func (*MockAdminServiceClientMockRecorder) ListHistoryTasks added in v1.16.0 

func (mr *MockAdminServiceClientMockRecorder) ListHistoryTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListHistoryTasks indicates an expected call of ListHistoryTasks.

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) RebuildMutableState added in v1.16.0 

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

RebuildMutableState indicates an expected call of RebuildMutableState.

func (*MockAdminServiceClientMockRecorder) RefreshWorkflowTasks 

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

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockAdminServiceClientMockRecorder) RemoveRemoteCluster added in v1.14.0 

func (mr *MockAdminServiceClientMockRecorder) RemoveRemoteCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveRemoteCluster indicates an expected call of RemoveRemoteCluster.

func (*MockAdminServiceClientMockRecorder) RemoveSearchAttributes added in v1.11.0 

func (mr *MockAdminServiceClientMockRecorder) RemoveSearchAttributes(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveSearchAttributes indicates an expected call of RemoveSearchAttributes.

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) AddOrUpdateRemoteCluster added in v1.14.0 

func (m *MockAdminServiceServer) AddOrUpdateRemoteCluster(arg0 context.Context, arg1 *adminservice.AddOrUpdateRemoteClusterRequest) (*adminservice.AddOrUpdateRemoteClusterResponse, error)

AddOrUpdateRemoteCluster mocks base method.

func (*MockAdminServiceServer) AddSearchAttributes added in v1.10.0 

func (m *MockAdminServiceServer) AddSearchAttributes(arg0 context.Context, arg1 *adminservice.AddSearchAttributesRequest) (*adminservice.AddSearchAttributesResponse, error)

AddSearchAttributes 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) DeleteWorkflowExecution added in v1.17.0 

func (m *MockAdminServiceServer) DeleteWorkflowExecution(arg0 context.Context, arg1 *adminservice.DeleteWorkflowExecutionRequest) (*adminservice.DeleteWorkflowExecutionResponse, error)

DeleteWorkflowExecution 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) DescribeMutableState added in v1.3.0 

func (m *MockAdminServiceServer) DescribeMutableState(arg0 context.Context, arg1 *adminservice.DescribeMutableStateRequest) (*adminservice.DescribeMutableStateResponse, error)

DescribeMutableState 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) GetSearchAttributes added in v1.10.0 

func (m *MockAdminServiceServer) GetSearchAttributes(arg0 context.Context, arg1 *adminservice.GetSearchAttributesRequest) (*adminservice.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockAdminServiceServer) GetShard added in v1.14.0 

func (m *MockAdminServiceServer) GetShard(arg0 context.Context, arg1 *adminservice.GetShardRequest) (*adminservice.GetShardResponse, error)

GetShard mocks base method.

func (*MockAdminServiceServer) GetTaskQueueTasks added in v1.14.0 

func (m *MockAdminServiceServer) GetTaskQueueTasks(arg0 context.Context, arg1 *adminservice.GetTaskQueueTasksRequest) (*adminservice.GetTaskQueueTasksResponse, error)

GetTaskQueueTasks 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) ListClusterMembers added in v1.14.0 

func (m *MockAdminServiceServer) ListClusterMembers(arg0 context.Context, arg1 *adminservice.ListClusterMembersRequest) (*adminservice.ListClusterMembersResponse, error)

ListClusterMembers mocks base method.

func (*MockAdminServiceServer) ListClusters added in v1.15.0 

func (m *MockAdminServiceServer) ListClusters(arg0 context.Context, arg1 *adminservice.ListClustersRequest) (*adminservice.ListClustersResponse, error)

ListClusters mocks base method.

func (*MockAdminServiceServer) ListHistoryTasks added in v1.16.0 

func (m *MockAdminServiceServer) ListHistoryTasks(arg0 context.Context, arg1 *adminservice.ListHistoryTasksRequest) (*adminservice.ListHistoryTasksResponse, error)

ListHistoryTasks 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) RebuildMutableState added in v1.16.0 

func (m *MockAdminServiceServer) RebuildMutableState(arg0 context.Context, arg1 *adminservice.RebuildMutableStateRequest) (*adminservice.RebuildMutableStateResponse, error)

RebuildMutableState 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) RemoveRemoteCluster added in v1.14.0 

func (m *MockAdminServiceServer) RemoveRemoteCluster(arg0 context.Context, arg1 *adminservice.RemoveRemoteClusterRequest) (*adminservice.RemoveRemoteClusterResponse, error)

RemoveRemoteCluster mocks base method.

func (*MockAdminServiceServer) RemoveSearchAttributes added in v1.11.0 

func (m *MockAdminServiceServer) RemoveSearchAttributes(arg0 context.Context, arg1 *adminservice.RemoveSearchAttributesRequest) (*adminservice.RemoveSearchAttributesResponse, error)

RemoveSearchAttributes 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) AddOrUpdateRemoteCluster added in v1.14.0 

func (mr *MockAdminServiceServerMockRecorder) AddOrUpdateRemoteCluster(arg0, arg1 interface{}) *gomock.Call

AddOrUpdateRemoteCluster indicates an expected call of AddOrUpdateRemoteCluster.

func (*MockAdminServiceServerMockRecorder) AddSearchAttributes added in v1.10.0 

func (mr *MockAdminServiceServerMockRecorder) AddSearchAttributes(arg0, arg1 interface{}) *gomock.Call

AddSearchAttributes indicates an expected call of AddSearchAttributes.

func (*MockAdminServiceServerMockRecorder) CloseShard 

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

CloseShard indicates an expected call of CloseShard.

func (*MockAdminServiceServerMockRecorder) DeleteWorkflowExecution added in v1.17.0 

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

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

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) DescribeMutableState added in v1.3.0 

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

DescribeMutableState indicates an expected call of DescribeMutableState.

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) GetSearchAttributes added in v1.10.0 

func (mr *MockAdminServiceServerMockRecorder) GetSearchAttributes(arg0, arg1 interface{}) *gomock.Call

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockAdminServiceServerMockRecorder) GetShard added in v1.14.0 

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

GetShard indicates an expected call of GetShard.

func (*MockAdminServiceServerMockRecorder) GetTaskQueueTasks added in v1.14.0 

func (mr *MockAdminServiceServerMockRecorder) GetTaskQueueTasks(arg0, arg1 interface{}) *gomock.Call

GetTaskQueueTasks indicates an expected call of GetTaskQueueTasks.

func (*MockAdminServiceServerMockRecorder) GetWorkflowExecutionRawHistoryV2 

func (mr *MockAdminServiceServerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call

GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.

func (*MockAdminServiceServerMockRecorder) ListClusterMembers added in v1.14.0 

func (mr *MockAdminServiceServerMockRecorder) ListClusterMembers(arg0, arg1 interface{}) *gomock.Call

ListClusterMembers indicates an expected call of ListClusterMembers.

func (*MockAdminServiceServerMockRecorder) ListClusters added in v1.15.0 

func (mr *MockAdminServiceServerMockRecorder) ListClusters(arg0, arg1 interface{}) *gomock.Call

ListClusters indicates an expected call of ListClusters.

func (*MockAdminServiceServerMockRecorder) ListHistoryTasks added in v1.16.0 

func (mr *MockAdminServiceServerMockRecorder) ListHistoryTasks(arg0, arg1 interface{}) *gomock.Call

ListHistoryTasks indicates an expected call of ListHistoryTasks.

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) RebuildMutableState added in v1.16.0 

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

RebuildMutableState indicates an expected call of RebuildMutableState.

func (*MockAdminServiceServerMockRecorder) RefreshWorkflowTasks 

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

RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.

func (*MockAdminServiceServerMockRecorder) RemoveRemoteCluster added in v1.14.0 

func (mr *MockAdminServiceServerMockRecorder) RemoveRemoteCluster(arg0, arg1 interface{}) *gomock.Call

RemoveRemoteCluster indicates an expected call of RemoveRemoteCluster.

func (*MockAdminServiceServerMockRecorder) RemoveSearchAttributes added in v1.11.0 

func (mr *MockAdminServiceServerMockRecorder) RemoveSearchAttributes(arg0, arg1 interface{}) *gomock.Call

RemoveSearchAttributes indicates an expected call of RemoveSearchAttributes.

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.

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.