admin

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2023 License: MIT Imports: 15 Imported by: 5

Documentation

Overview

Package admin is a generated GoMock package.

Index

Constants

View Source 
const (
	// DefaultTimeout is the default timeout used to make calls
	DefaultTimeout = 10 * time.Second
	// DefaultLargeTimeout is the default timeout used to make calls
	DefaultLargeTimeout = time.Minute
)

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
	GetCrossClusterTasks(context.Context, *types.GetCrossClusterTasksRequest, ...yarpc.CallOption) (*types.GetCrossClusterTasksResponse, error)
	RespondCrossClusterTasksCompleted(context.Context, *types.RespondCrossClusterTasksCompletedRequest, ...yarpc.CallOption) (*types.RespondCrossClusterTasksCompletedResponse, 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)
}

Client is the interface exposed by admin service client

func NewClient 

func NewClient(
	timeout time.Duration,
	largeTimeout time.Duration,
	client Client,
) Client

NewClient creates a new admin service TChannel client

func NewErrorInjectionClient added in v0.18.0 

func NewErrorInjectionClient(
	client Client,
	errorRate float64,
	logger log.Logger,
) Client

NewErrorInjectionClient creates a new instance of Client that injects fake error

func NewGRPCClient added in v0.21.0 

func NewGRPCClient(c adminv1.AdminAPIYARPCClient) Client

func NewMetricClient 

func NewMetricClient(client Client, metricsClient metrics.Client) Client

NewMetricClient creates a new instance of Client that emits metrics

func NewRetryableClient 

func NewRetryableClient(client Client, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) Client

NewRetryableClient creates a new instance of Client with retry policy

func NewThriftClient added in v0.17.0 

func NewThriftClient(c adminserviceclient.Interface) Client

NewThriftClient creates a new instance of Client with thrift protocol

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) GetCrossClusterTasks added in v0.23.1 

func (m *MockClient) GetCrossClusterTasks(arg0 context.Context, arg1 *types.GetCrossClusterTasksRequest, arg2 ...yarpc.CallOption) (*types.GetCrossClusterTasksResponse, error)

GetCrossClusterTasks mocks base method.

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) 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) 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) RespondCrossClusterTasksCompleted added in v0.24.0 

func (m *MockClient) RespondCrossClusterTasksCompleted(arg0 context.Context, arg1 *types.RespondCrossClusterTasksCompletedRequest, arg2 ...yarpc.CallOption) (*types.RespondCrossClusterTasksCompletedResponse, error)

RespondCrossClusterTasksCompleted 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) UpdateDynamicConfig added in v0.23.1 

func (m *MockClient) UpdateDynamicConfig(arg0 context.Context, arg1 *types.UpdateDynamicConfigRequest, arg2 ...yarpc.CallOption) error

UpdateDynamicConfig 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) GetCrossClusterTasks added in v0.23.1 

func (mr *MockClientMockRecorder) GetCrossClusterTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetCrossClusterTasks indicates an expected call of GetCrossClusterTasks.

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) 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) 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) RespondCrossClusterTasksCompleted added in v0.24.0 

func (mr *MockClientMockRecorder) RespondCrossClusterTasksCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondCrossClusterTasksCompleted indicates an expected call of RespondCrossClusterTasksCompleted.

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) UpdateDynamicConfig added in v0.23.1 

func (mr *MockClientMockRecorder) UpdateDynamicConfig(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateDynamicConfig indicates an expected call of UpdateDynamicConfig.

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.