Documentation ¶
Overview ¶
Package admin is a generated GoMock package.
Index ¶
- type Handler
- type MockHandler
- func (m *MockHandler) AddSearchAttribute(arg0 context.Context, arg1 *types.AddSearchAttributeRequest) error
- func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error
- func (m *MockHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.CountDLQMessagesResponse, error)
- func (m *MockHandler) DeleteWorkflow(arg0 context.Context, arg1 *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error)
- func (m *MockHandler) DescribeCluster(arg0 context.Context) (*types.DescribeClusterResponse, error)
- func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
- func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
- func (m *MockHandler) DescribeShardDistribution(arg0 context.Context, arg1 *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error)
- func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, error)
- func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
- func (m *MockHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
- func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
- func (m *MockHandler) GetDomainAsyncWorkflowConfiguraton(arg0 context.Context, arg1 *types.GetDomainAsyncWorkflowConfiguratonRequest) (*types.GetDomainAsyncWorkflowConfiguratonResponse, error)
- func (m *MockHandler) GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest) (*types.GetDomainIsolationGroupsResponse, error)
- func (m *MockHandler) GetDomainReplicationMessages(arg0 context.Context, arg1 *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error)
- func (m *MockHandler) GetDynamicConfig(arg0 context.Context, arg1 *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error)
- func (m *MockHandler) GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest) (*types.GetGlobalIsolationGroupsResponse, error)
- func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
- func (m *MockHandler) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error)
- func (m *MockHandler) ListDynamicConfig(arg0 context.Context, arg1 *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error)
- func (m *MockHandler) MaintainCorruptWorkflow(arg0 context.Context, arg1 *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error)
- func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
- func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error
- func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
- func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.ReapplyEventsRequest) error
- func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.RefreshWorkflowTasksRequest) error
- func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error
- func (m *MockHandler) ResendReplicationTasks(arg0 context.Context, arg1 *types.ResendReplicationTasksRequest) error
- func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error
- func (m *MockHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
- func (m *MockHandler) RestoreDynamicConfig(arg0 context.Context, arg1 *types.RestoreDynamicConfigRequest) error
- func (m *MockHandler) Start()
- func (m *MockHandler) Stop()
- func (m *MockHandler) UpdateDomainAsyncWorkflowConfiguraton(arg0 context.Context, arg1 *types.UpdateDomainAsyncWorkflowConfiguratonRequest) (*types.UpdateDomainAsyncWorkflowConfiguratonResponse, error)
- func (m *MockHandler) UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest) (*types.UpdateDomainIsolationGroupsResponse, error)
- func (m *MockHandler) UpdateDynamicConfig(arg0 context.Context, arg1 *types.UpdateDynamicConfigRequest) error
- func (m *MockHandler) UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest) (*types.UpdateGlobalIsolationGroupsResponse, error)
- func (m *MockHandler) UpdateTaskListPartitionConfig(arg0 context.Context, arg1 *types.UpdateTaskListPartitionConfigRequest) (*types.UpdateTaskListPartitionConfigResponse, error)
- type MockHandlerMockRecorder
- func (mr *MockHandlerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) CountDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DeleteWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeShardDistribution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDomainAsyncWorkflowConfiguraton(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDomainIsolationGroups(ctx, request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDomainReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetDynamicConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetGlobalIsolationGroups(ctx, request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListDynamicConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) MaintainCorruptWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RestoreDynamicConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) Start() *gomock.Call
- func (mr *MockHandlerMockRecorder) Stop() *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateDomainAsyncWorkflowConfiguraton(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateDomainIsolationGroups(ctx, request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateDynamicConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateGlobalIsolationGroups(ctx, request interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateTaskListPartitionConfig(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler interface { common.Daemon AddSearchAttribute(context.Context, *types.AddSearchAttributeRequest) error CloseShard(context.Context, *types.CloseShardRequest) error DescribeCluster(context.Context) (*types.DescribeClusterResponse, error) DescribeShardDistribution(context.Context, *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error) DescribeHistoryHost(context.Context, *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error) DescribeQueue(context.Context, *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error) DescribeWorkflowExecution(context.Context, *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, error) GetDLQReplicationMessages(context.Context, *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error) GetDomainReplicationMessages(context.Context, *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error) GetReplicationMessages(context.Context, *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error) GetWorkflowExecutionRawHistoryV2(context.Context, *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error) CountDLQMessages(context.Context, *types.CountDLQMessagesRequest) (*types.CountDLQMessagesResponse, error) MergeDLQMessages(context.Context, *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error) PurgeDLQMessages(context.Context, *types.PurgeDLQMessagesRequest) error ReadDLQMessages(context.Context, *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error) ReapplyEvents(context.Context, *types.ReapplyEventsRequest) error RefreshWorkflowTasks(context.Context, *types.RefreshWorkflowTasksRequest) error RemoveTask(context.Context, *types.RemoveTaskRequest) error ResendReplicationTasks(context.Context, *types.ResendReplicationTasksRequest) error ResetQueue(context.Context, *types.ResetQueueRequest) error GetCrossClusterTasks(context.Context, *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error) RespondCrossClusterTasksCompleted(context.Context, *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error) GetDynamicConfig(context.Context, *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error) UpdateDynamicConfig(context.Context, *types.UpdateDynamicConfigRequest) error RestoreDynamicConfig(context.Context, *types.RestoreDynamicConfigRequest) error ListDynamicConfig(context.Context, *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error) DeleteWorkflow(context.Context, *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error) MaintainCorruptWorkflow(context.Context, *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error) GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest) (*types.GetGlobalIsolationGroupsResponse, error) UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest) (*types.UpdateGlobalIsolationGroupsResponse, error) GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest) (*types.GetDomainIsolationGroupsResponse, error) UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest) (*types.UpdateDomainIsolationGroupsResponse, error) GetDomainAsyncWorkflowConfiguraton(context.Context, *types.GetDomainAsyncWorkflowConfiguratonRequest) (*types.GetDomainAsyncWorkflowConfiguratonResponse, error) UpdateDomainAsyncWorkflowConfiguraton(context.Context, *types.UpdateDomainAsyncWorkflowConfiguratonRequest) (*types.UpdateDomainAsyncWorkflowConfiguratonResponse, error) UpdateTaskListPartitionConfig(context.Context, *types.UpdateTaskListPartitionConfigRequest) (*types.UpdateTaskListPartitionConfigResponse, error) }
Handler interface for admin service
type MockHandler ¶
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface.
func NewMockHandler ¶
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance.
func (*MockHandler) AddSearchAttribute ¶
func (m *MockHandler) AddSearchAttribute(arg0 context.Context, arg1 *types.AddSearchAttributeRequest) error
AddSearchAttribute mocks base method.
func (*MockHandler) CloseShard ¶
func (m *MockHandler) CloseShard(arg0 context.Context, arg1 *types.CloseShardRequest) error
CloseShard mocks base method.
func (*MockHandler) CountDLQMessages ¶
func (m *MockHandler) CountDLQMessages(arg0 context.Context, arg1 *types.CountDLQMessagesRequest) (*types.CountDLQMessagesResponse, error)
CountDLQMessages mocks base method.
func (*MockHandler) DeleteWorkflow ¶
func (m *MockHandler) DeleteWorkflow(arg0 context.Context, arg1 *types.AdminDeleteWorkflowRequest) (*types.AdminDeleteWorkflowResponse, error)
DeleteWorkflow mocks base method.
func (*MockHandler) DescribeCluster ¶
func (m *MockHandler) DescribeCluster(arg0 context.Context) (*types.DescribeClusterResponse, error)
DescribeCluster mocks base method.
func (*MockHandler) DescribeHistoryHost ¶
func (m *MockHandler) DescribeHistoryHost(arg0 context.Context, arg1 *types.DescribeHistoryHostRequest) (*types.DescribeHistoryHostResponse, error)
DescribeHistoryHost mocks base method.
func (*MockHandler) DescribeQueue ¶
func (m *MockHandler) DescribeQueue(arg0 context.Context, arg1 *types.DescribeQueueRequest) (*types.DescribeQueueResponse, error)
DescribeQueue mocks base method.
func (*MockHandler) DescribeShardDistribution ¶
func (m *MockHandler) DescribeShardDistribution(arg0 context.Context, arg1 *types.DescribeShardDistributionRequest) (*types.DescribeShardDistributionResponse, error)
DescribeShardDistribution mocks base method.
func (*MockHandler) DescribeWorkflowExecution ¶
func (m *MockHandler) DescribeWorkflowExecution(arg0 context.Context, arg1 *types.AdminDescribeWorkflowExecutionRequest) (*types.AdminDescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockHandler) EXPECT ¶
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHandler) GetCrossClusterTasks ¶
func (m *MockHandler) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest) (*types.GetCrossClusterTasksResponse, error)
GetCrossClusterTasks mocks base method.
func (*MockHandler) GetDLQReplicationMessages ¶
func (m *MockHandler) GetDLQReplicationMessages(arg0 context.Context, arg1 *types.GetDLQReplicationMessagesRequest) (*types.GetDLQReplicationMessagesResponse, error)
GetDLQReplicationMessages mocks base method.
func (*MockHandler) GetDomainAsyncWorkflowConfiguraton ¶
func (m *MockHandler) GetDomainAsyncWorkflowConfiguraton(arg0 context.Context, arg1 *types.GetDomainAsyncWorkflowConfiguratonRequest) (*types.GetDomainAsyncWorkflowConfiguratonResponse, error)
GetDomainAsyncWorkflowConfiguraton mocks base method.
func (*MockHandler) GetDomainIsolationGroups ¶
func (m *MockHandler) GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest) (*types.GetDomainIsolationGroupsResponse, error)
GetDomainIsolationGroups mocks base method.
func (*MockHandler) GetDomainReplicationMessages ¶
func (m *MockHandler) GetDomainReplicationMessages(arg0 context.Context, arg1 *types.GetDomainReplicationMessagesRequest) (*types.GetDomainReplicationMessagesResponse, error)
GetDomainReplicationMessages mocks base method.
func (*MockHandler) GetDynamicConfig ¶
func (m *MockHandler) GetDynamicConfig(arg0 context.Context, arg1 *types.GetDynamicConfigRequest) (*types.GetDynamicConfigResponse, error)
GetDynamicConfig mocks base method.
func (*MockHandler) GetGlobalIsolationGroups ¶
func (m *MockHandler) GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest) (*types.GetGlobalIsolationGroupsResponse, error)
GetGlobalIsolationGroups mocks base method.
func (*MockHandler) GetReplicationMessages ¶
func (m *MockHandler) GetReplicationMessages(arg0 context.Context, arg1 *types.GetReplicationMessagesRequest) (*types.GetReplicationMessagesResponse, error)
GetReplicationMessages mocks base method.
func (*MockHandler) GetWorkflowExecutionRawHistoryV2 ¶
func (m *MockHandler) GetWorkflowExecutionRawHistoryV2(arg0 context.Context, arg1 *types.GetWorkflowExecutionRawHistoryV2Request) (*types.GetWorkflowExecutionRawHistoryV2Response, error)
GetWorkflowExecutionRawHistoryV2 mocks base method.
func (*MockHandler) ListDynamicConfig ¶
func (m *MockHandler) ListDynamicConfig(arg0 context.Context, arg1 *types.ListDynamicConfigRequest) (*types.ListDynamicConfigResponse, error)
ListDynamicConfig mocks base method.
func (*MockHandler) MaintainCorruptWorkflow ¶
func (m *MockHandler) MaintainCorruptWorkflow(arg0 context.Context, arg1 *types.AdminMaintainWorkflowRequest) (*types.AdminMaintainWorkflowResponse, error)
MaintainCorruptWorkflow mocks base method.
func (*MockHandler) MergeDLQMessages ¶
func (m *MockHandler) MergeDLQMessages(arg0 context.Context, arg1 *types.MergeDLQMessagesRequest) (*types.MergeDLQMessagesResponse, error)
MergeDLQMessages mocks base method.
func (*MockHandler) PurgeDLQMessages ¶
func (m *MockHandler) PurgeDLQMessages(arg0 context.Context, arg1 *types.PurgeDLQMessagesRequest) error
PurgeDLQMessages mocks base method.
func (*MockHandler) ReadDLQMessages ¶
func (m *MockHandler) ReadDLQMessages(arg0 context.Context, arg1 *types.ReadDLQMessagesRequest) (*types.ReadDLQMessagesResponse, error)
ReadDLQMessages mocks base method.
func (*MockHandler) ReapplyEvents ¶
func (m *MockHandler) ReapplyEvents(arg0 context.Context, arg1 *types.ReapplyEventsRequest) error
ReapplyEvents mocks base method.
func (*MockHandler) RefreshWorkflowTasks ¶
func (m *MockHandler) RefreshWorkflowTasks(arg0 context.Context, arg1 *types.RefreshWorkflowTasksRequest) error
RefreshWorkflowTasks mocks base method.
func (*MockHandler) RemoveTask ¶
func (m *MockHandler) RemoveTask(arg0 context.Context, arg1 *types.RemoveTaskRequest) error
RemoveTask mocks base method.
func (*MockHandler) ResendReplicationTasks ¶
func (m *MockHandler) ResendReplicationTasks(arg0 context.Context, arg1 *types.ResendReplicationTasksRequest) error
ResendReplicationTasks mocks base method.
func (*MockHandler) ResetQueue ¶
func (m *MockHandler) ResetQueue(arg0 context.Context, arg1 *types.ResetQueueRequest) error
ResetQueue mocks base method.
func (*MockHandler) RespondCrossClusterTasksCompleted ¶
func (m *MockHandler) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest) (*types.RespondCrossClusterTasksCompletedResponse, error)
RespondCrossClusterTasksCompleted mocks base method.
func (*MockHandler) RestoreDynamicConfig ¶
func (m *MockHandler) RestoreDynamicConfig(arg0 context.Context, arg1 *types.RestoreDynamicConfigRequest) error
RestoreDynamicConfig mocks base method.
func (*MockHandler) UpdateDomainAsyncWorkflowConfiguraton ¶
func (m *MockHandler) UpdateDomainAsyncWorkflowConfiguraton(arg0 context.Context, arg1 *types.UpdateDomainAsyncWorkflowConfiguratonRequest) (*types.UpdateDomainAsyncWorkflowConfiguratonResponse, error)
UpdateDomainAsyncWorkflowConfiguraton mocks base method.
func (*MockHandler) UpdateDomainIsolationGroups ¶
func (m *MockHandler) UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest) (*types.UpdateDomainIsolationGroupsResponse, error)
UpdateDomainIsolationGroups mocks base method.
func (*MockHandler) UpdateDynamicConfig ¶
func (m *MockHandler) UpdateDynamicConfig(arg0 context.Context, arg1 *types.UpdateDynamicConfigRequest) error
UpdateDynamicConfig mocks base method.
func (*MockHandler) UpdateGlobalIsolationGroups ¶
func (m *MockHandler) UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest) (*types.UpdateGlobalIsolationGroupsResponse, error)
UpdateGlobalIsolationGroups mocks base method.
func (*MockHandler) UpdateTaskListPartitionConfig ¶
func (m *MockHandler) UpdateTaskListPartitionConfig(arg0 context.Context, arg1 *types.UpdateTaskListPartitionConfigRequest) (*types.UpdateTaskListPartitionConfigResponse, error)
UpdateTaskListPartitionConfig mocks base method.
type MockHandlerMockRecorder ¶
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler.
func (*MockHandlerMockRecorder) AddSearchAttribute ¶
func (mr *MockHandlerMockRecorder) AddSearchAttribute(arg0, arg1 interface{}) *gomock.Call
AddSearchAttribute indicates an expected call of AddSearchAttribute.
func (*MockHandlerMockRecorder) CloseShard ¶
func (mr *MockHandlerMockRecorder) CloseShard(arg0, arg1 interface{}) *gomock.Call
CloseShard indicates an expected call of CloseShard.
func (*MockHandlerMockRecorder) CountDLQMessages ¶
func (mr *MockHandlerMockRecorder) CountDLQMessages(arg0, arg1 interface{}) *gomock.Call
CountDLQMessages indicates an expected call of CountDLQMessages.
func (*MockHandlerMockRecorder) DeleteWorkflow ¶
func (mr *MockHandlerMockRecorder) DeleteWorkflow(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflow indicates an expected call of DeleteWorkflow.
func (*MockHandlerMockRecorder) DescribeCluster ¶
func (mr *MockHandlerMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
DescribeCluster indicates an expected call of DescribeCluster.
func (*MockHandlerMockRecorder) DescribeHistoryHost ¶
func (mr *MockHandlerMockRecorder) DescribeHistoryHost(arg0, arg1 interface{}) *gomock.Call
DescribeHistoryHost indicates an expected call of DescribeHistoryHost.
func (*MockHandlerMockRecorder) DescribeQueue ¶
func (mr *MockHandlerMockRecorder) DescribeQueue(arg0, arg1 interface{}) *gomock.Call
DescribeQueue indicates an expected call of DescribeQueue.
func (*MockHandlerMockRecorder) DescribeShardDistribution ¶
func (mr *MockHandlerMockRecorder) DescribeShardDistribution(arg0, arg1 interface{}) *gomock.Call
DescribeShardDistribution indicates an expected call of DescribeShardDistribution.
func (*MockHandlerMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockHandlerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockHandlerMockRecorder) GetCrossClusterTasks ¶
func (mr *MockHandlerMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}) *gomock.Call
GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.
func (*MockHandlerMockRecorder) GetDLQReplicationMessages ¶
func (mr *MockHandlerMockRecorder) GetDLQReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDLQReplicationMessages indicates an expected call of GetDLQReplicationMessages.
func (*MockHandlerMockRecorder) GetDomainAsyncWorkflowConfiguraton ¶
func (mr *MockHandlerMockRecorder) GetDomainAsyncWorkflowConfiguraton(arg0, arg1 interface{}) *gomock.Call
GetDomainAsyncWorkflowConfiguraton indicates an expected call of GetDomainAsyncWorkflowConfiguraton.
func (*MockHandlerMockRecorder) GetDomainIsolationGroups ¶
func (mr *MockHandlerMockRecorder) GetDomainIsolationGroups(ctx, request interface{}) *gomock.Call
GetDomainIsolationGroups indicates an expected call of GetDomainIsolationGroups.
func (*MockHandlerMockRecorder) GetDomainReplicationMessages ¶
func (mr *MockHandlerMockRecorder) GetDomainReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetDomainReplicationMessages indicates an expected call of GetDomainReplicationMessages.
func (*MockHandlerMockRecorder) GetDynamicConfig ¶
func (mr *MockHandlerMockRecorder) GetDynamicConfig(arg0, arg1 interface{}) *gomock.Call
GetDynamicConfig indicates an expected call of GetDynamicConfig.
func (*MockHandlerMockRecorder) GetGlobalIsolationGroups ¶
func (mr *MockHandlerMockRecorder) GetGlobalIsolationGroups(ctx, request interface{}) *gomock.Call
GetGlobalIsolationGroups indicates an expected call of GetGlobalIsolationGroups.
func (*MockHandlerMockRecorder) GetReplicationMessages ¶
func (mr *MockHandlerMockRecorder) GetReplicationMessages(arg0, arg1 interface{}) *gomock.Call
GetReplicationMessages indicates an expected call of GetReplicationMessages.
func (*MockHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2 ¶
func (mr *MockHandlerMockRecorder) GetWorkflowExecutionRawHistoryV2(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecutionRawHistoryV2 indicates an expected call of GetWorkflowExecutionRawHistoryV2.
func (*MockHandlerMockRecorder) ListDynamicConfig ¶
func (mr *MockHandlerMockRecorder) ListDynamicConfig(arg0, arg1 interface{}) *gomock.Call
ListDynamicConfig indicates an expected call of ListDynamicConfig.
func (*MockHandlerMockRecorder) MaintainCorruptWorkflow ¶
func (mr *MockHandlerMockRecorder) MaintainCorruptWorkflow(arg0, arg1 interface{}) *gomock.Call
MaintainCorruptWorkflow indicates an expected call of MaintainCorruptWorkflow.
func (*MockHandlerMockRecorder) MergeDLQMessages ¶
func (mr *MockHandlerMockRecorder) MergeDLQMessages(arg0, arg1 interface{}) *gomock.Call
MergeDLQMessages indicates an expected call of MergeDLQMessages.
func (*MockHandlerMockRecorder) PurgeDLQMessages ¶
func (mr *MockHandlerMockRecorder) PurgeDLQMessages(arg0, arg1 interface{}) *gomock.Call
PurgeDLQMessages indicates an expected call of PurgeDLQMessages.
func (*MockHandlerMockRecorder) ReadDLQMessages ¶
func (mr *MockHandlerMockRecorder) ReadDLQMessages(arg0, arg1 interface{}) *gomock.Call
ReadDLQMessages indicates an expected call of ReadDLQMessages.
func (*MockHandlerMockRecorder) ReapplyEvents ¶
func (mr *MockHandlerMockRecorder) ReapplyEvents(arg0, arg1 interface{}) *gomock.Call
ReapplyEvents indicates an expected call of ReapplyEvents.
func (*MockHandlerMockRecorder) RefreshWorkflowTasks ¶
func (mr *MockHandlerMockRecorder) RefreshWorkflowTasks(arg0, arg1 interface{}) *gomock.Call
RefreshWorkflowTasks indicates an expected call of RefreshWorkflowTasks.
func (*MockHandlerMockRecorder) RemoveTask ¶
func (mr *MockHandlerMockRecorder) RemoveTask(arg0, arg1 interface{}) *gomock.Call
RemoveTask indicates an expected call of RemoveTask.
func (*MockHandlerMockRecorder) ResendReplicationTasks ¶
func (mr *MockHandlerMockRecorder) ResendReplicationTasks(arg0, arg1 interface{}) *gomock.Call
ResendReplicationTasks indicates an expected call of ResendReplicationTasks.
func (*MockHandlerMockRecorder) ResetQueue ¶
func (mr *MockHandlerMockRecorder) ResetQueue(arg0, arg1 interface{}) *gomock.Call
ResetQueue indicates an expected call of ResetQueue.
func (*MockHandlerMockRecorder) RespondCrossClusterTasksCompleted ¶
func (mr *MockHandlerMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}) *gomock.Call
RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.
func (*MockHandlerMockRecorder) RestoreDynamicConfig ¶
func (mr *MockHandlerMockRecorder) RestoreDynamicConfig(arg0, arg1 interface{}) *gomock.Call
RestoreDynamicConfig indicates an expected call of RestoreDynamicConfig.
func (*MockHandlerMockRecorder) Start ¶
func (mr *MockHandlerMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockHandlerMockRecorder) Stop ¶
func (mr *MockHandlerMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockHandlerMockRecorder) UpdateDomainAsyncWorkflowConfiguraton ¶
func (mr *MockHandlerMockRecorder) UpdateDomainAsyncWorkflowConfiguraton(arg0, arg1 interface{}) *gomock.Call
UpdateDomainAsyncWorkflowConfiguraton indicates an expected call of UpdateDomainAsyncWorkflowConfiguraton.
func (*MockHandlerMockRecorder) UpdateDomainIsolationGroups ¶
func (mr *MockHandlerMockRecorder) UpdateDomainIsolationGroups(ctx, request interface{}) *gomock.Call
UpdateDomainIsolationGroups indicates an expected call of UpdateDomainIsolationGroups.
func (*MockHandlerMockRecorder) UpdateDynamicConfig ¶
func (mr *MockHandlerMockRecorder) UpdateDynamicConfig(arg0, arg1 interface{}) *gomock.Call
UpdateDynamicConfig indicates an expected call of UpdateDynamicConfig.
func (*MockHandlerMockRecorder) UpdateGlobalIsolationGroups ¶
func (mr *MockHandlerMockRecorder) UpdateGlobalIsolationGroups(ctx, request interface{}) *gomock.Call
UpdateGlobalIsolationGroups indicates an expected call of UpdateGlobalIsolationGroups.
func (*MockHandlerMockRecorder) UpdateTaskListPartitionConfig ¶
func (mr *MockHandlerMockRecorder) UpdateTaskListPartitionConfig(arg0, arg1 interface{}) *gomock.Call
UpdateTaskListPartitionConfig indicates an expected call of UpdateTaskListPartitionConfig.