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