admin

package
v1.2.15-prerelease05 Latest Latest
Warning

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

Go to latest
Published: Nov 27, 2024 License: MIT Imports: 34 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)
	UpdateTaskListPartitionConfig(context.Context, *types.UpdateTaskListPartitionConfigRequest) (*types.UpdateTaskListPartitionConfigResponse, 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

CountDLQMessages mocks base method.

func (*MockHandler) DeleteWorkflow

DeleteWorkflow mocks base method.

func (*MockHandler) DescribeCluster

func (m *MockHandler) DescribeCluster(arg0 context.Context) (*types.DescribeClusterResponse, error)

DescribeCluster mocks base method.

func (*MockHandler) DescribeHistoryHost

DescribeHistoryHost mocks base method.

func (*MockHandler) DescribeQueue

DescribeQueue mocks base method.

func (*MockHandler) DescribeShardDistribution

DescribeShardDistribution mocks base method.

func (*MockHandler) DescribeWorkflowExecution

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

GetCrossClusterTasks mocks base method.

func (*MockHandler) GetDLQReplicationMessages

GetDLQReplicationMessages mocks base method.

func (*MockHandler) GetDomainAsyncWorkflowConfiguraton

GetDomainAsyncWorkflowConfiguraton mocks base method.

func (*MockHandler) GetDomainIsolationGroups

GetDomainIsolationGroups mocks base method.

func (*MockHandler) GetDomainReplicationMessages

GetDomainReplicationMessages mocks base method.

func (*MockHandler) GetDynamicConfig

GetDynamicConfig mocks base method.

func (*MockHandler) GetGlobalIsolationGroups

GetGlobalIsolationGroups mocks base method.

func (*MockHandler) GetReplicationMessages

GetReplicationMessages mocks base method.

func (*MockHandler) GetWorkflowExecutionRawHistoryV2

GetWorkflowExecutionRawHistoryV2 mocks base method.

func (*MockHandler) ListDynamicConfig

ListDynamicConfig mocks base method.

func (*MockHandler) MaintainCorruptWorkflow

MaintainCorruptWorkflow mocks base method.

func (*MockHandler) MergeDLQMessages

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

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

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

UpdateDomainAsyncWorkflowConfiguraton mocks base method.

func (*MockHandler) UpdateDomainIsolationGroups

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

UpdateGlobalIsolationGroups mocks base method.

func (*MockHandler) UpdateTaskListPartitionConfig

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL