admin

package
v1.2.7-prerelease7 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2024 License: MIT Imports: 32 Imported by: 0

Documentation

Overview

Package admin is a generated GoMock package.

Index

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)
}

Handler interface for admin service

func NewHandler 

func NewHandler(
	resource resource.Resource,
	params *resource.Params,
	config *config.Config,
	domainHandler domain.Handler,
) Handler

NewHandler creates a thrift service for the cadence 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) Start 

func (m *MockHandler) Start()

Start mocks base method.

func (*MockHandler) Stop 

func (m *MockHandler) Stop()

Stop 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.

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.

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.