resource

package
v1.2.13-prerelease11 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2024 License: MIT Imports: 37 Imported by: 0

Documentation

Overview

Package resource is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockResource added in v1.2.10 

type MockResource struct {
	// contains filtered or unexported fields
}

MockResource is a mock of Resource interface.

func NewMockResource added in v1.2.10 

func NewMockResource(ctrl *gomock.Controller) *MockResource

NewMockResource creates a new mock instance.

func (*MockResource) EXPECT added in v1.2.10 

func (m *MockResource) EXPECT() *MockResourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockResource) GetArchivalMetadata added in v1.2.10 

func (m *MockResource) GetArchivalMetadata() archiver.ArchivalMetadata

GetArchivalMetadata mocks base method.

func (*MockResource) GetArchiverProvider added in v1.2.10 

func (m *MockResource) GetArchiverProvider() provider.ArchiverProvider

GetArchiverProvider mocks base method.

func (*MockResource) GetAsyncWorkflowQueueProvider added in v1.2.10 

func (m *MockResource) GetAsyncWorkflowQueueProvider() queue.Provider

GetAsyncWorkflowQueueProvider mocks base method.

func (*MockResource) GetBlobstoreClient added in v1.2.10 

func (m *MockResource) GetBlobstoreClient() blobstore.Client

GetBlobstoreClient mocks base method.

func (*MockResource) GetClientBean added in v1.2.10 

func (m *MockResource) GetClientBean() client.Bean

GetClientBean mocks base method.

func (*MockResource) GetClusterMetadata added in v1.2.10 

func (m *MockResource) GetClusterMetadata() cluster.Metadata

GetClusterMetadata mocks base method.

func (*MockResource) GetDispatcher added in v1.2.10 

func (m *MockResource) GetDispatcher() *yarpc.Dispatcher

GetDispatcher mocks base method.

func (*MockResource) GetDomainCache added in v1.2.10 

func (m *MockResource) GetDomainCache() cache.DomainCache

GetDomainCache mocks base method.

func (*MockResource) GetDomainManager added in v1.2.10 

func (m *MockResource) GetDomainManager() persistence.DomainManager

GetDomainManager mocks base method.

func (*MockResource) GetDomainMetricsScopeCache added in v1.2.10 

func (m *MockResource) GetDomainMetricsScopeCache() cache.DomainMetricsScopeCache

GetDomainMetricsScopeCache mocks base method.

func (*MockResource) GetDomainReplicationQueue added in v1.2.10 

func (m *MockResource) GetDomainReplicationQueue() domain.ReplicationQueue

GetDomainReplicationQueue mocks base method.

func (*MockResource) GetEventCache added in v1.2.10 

func (m *MockResource) GetEventCache() events.Cache

GetEventCache mocks base method.

func (*MockResource) GetExecutionManager added in v1.2.10 

func (m *MockResource) GetExecutionManager(arg0 int) (persistence.ExecutionManager, error)

GetExecutionManager mocks base method.

func (*MockResource) GetFrontendClient added in v1.2.10 

func (m *MockResource) GetFrontendClient() frontend.Client

GetFrontendClient mocks base method.

func (*MockResource) GetFrontendRawClient added in v1.2.10 

func (m *MockResource) GetFrontendRawClient() frontend.Client

GetFrontendRawClient mocks base method.

func (*MockResource) GetHistoryClient added in v1.2.10 

func (m *MockResource) GetHistoryClient() history.Client

GetHistoryClient mocks base method.

func (*MockResource) GetHistoryManager added in v1.2.10 

func (m *MockResource) GetHistoryManager() persistence.HistoryManager

GetHistoryManager mocks base method.

func (*MockResource) GetHistoryRawClient added in v1.2.10 

func (m *MockResource) GetHistoryRawClient() history.Client

GetHistoryRawClient mocks base method.

func (*MockResource) GetHostInfo added in v1.2.10 

func (m *MockResource) GetHostInfo() membership.HostInfo

GetHostInfo mocks base method.

func (*MockResource) GetHostName added in v1.2.10 

func (m *MockResource) GetHostName() string

GetHostName mocks base method.

func (*MockResource) GetIsolationGroupState added in v1.2.10 

func (m *MockResource) GetIsolationGroupState() isolationgroup.State

GetIsolationGroupState mocks base method.

func (*MockResource) GetIsolationGroupStore added in v1.2.10 

func (m *MockResource) GetIsolationGroupStore() configstore.Client

GetIsolationGroupStore mocks base method.

func (*MockResource) GetLogger added in v1.2.10 

func (m *MockResource) GetLogger() log.Logger

GetLogger mocks base method.

func (*MockResource) GetMatchingClient added in v1.2.10 

func (m *MockResource) GetMatchingClient() matching.Client

GetMatchingClient mocks base method.

func (*MockResource) GetMatchingRawClient added in v1.2.10 

func (m *MockResource) GetMatchingRawClient() matching.Client

GetMatchingRawClient mocks base method.

func (*MockResource) GetMembershipResolver added in v1.2.10 

func (m *MockResource) GetMembershipResolver() membership.Resolver

GetMembershipResolver mocks base method.

func (*MockResource) GetMessagingClient added in v1.2.10 

func (m *MockResource) GetMessagingClient() messaging.Client

GetMessagingClient mocks base method.

func (*MockResource) GetMetricsClient added in v1.2.10 

func (m *MockResource) GetMetricsClient() metrics.Client

GetMetricsClient mocks base method.

func (*MockResource) GetPartitioner added in v1.2.10 

func (m *MockResource) GetPartitioner() partition.Partitioner

GetPartitioner mocks base method.

func (*MockResource) GetPayloadSerializer added in v1.2.10 

func (m *MockResource) GetPayloadSerializer() persistence.PayloadSerializer

GetPayloadSerializer mocks base method.

func (*MockResource) GetPersistenceBean added in v1.2.10 

func (m *MockResource) GetPersistenceBean() client0.Bean

GetPersistenceBean mocks base method.

func (*MockResource) GetRatelimiterAggregatorsClient added in v1.2.12 

func (m *MockResource) GetRatelimiterAggregatorsClient() rpc.Client

GetRatelimiterAggregatorsClient mocks base method.

func (*MockResource) GetRatelimiterAlgorithm added in v1.2.12 

func (m *MockResource) GetRatelimiterAlgorithm() algorithm.RequestWeighted

GetRatelimiterAlgorithm mocks base method.

func (*MockResource) GetRemoteAdminClient added in v1.2.10 

func (m *MockResource) GetRemoteAdminClient(cluster string) admin.Client

GetRemoteAdminClient mocks base method.

func (*MockResource) GetRemoteFrontendClient added in v1.2.10 

func (m *MockResource) GetRemoteFrontendClient(cluster string) frontend.Client

GetRemoteFrontendClient mocks base method.

func (*MockResource) GetSDKClient added in v1.2.10 

func (m *MockResource) GetSDKClient() workflowserviceclient.Interface

GetSDKClient mocks base method.

func (*MockResource) GetServiceName added in v1.2.10 

func (m *MockResource) GetServiceName() string

GetServiceName mocks base method.

func (*MockResource) GetShardManager added in v1.2.10 

func (m *MockResource) GetShardManager() persistence.ShardManager

GetShardManager mocks base method.

func (*MockResource) GetTaskManager added in v1.2.10 

func (m *MockResource) GetTaskManager() persistence.TaskManager

GetTaskManager mocks base method.

func (*MockResource) GetThrottledLogger added in v1.2.10 

func (m *MockResource) GetThrottledLogger() log.Logger

GetThrottledLogger mocks base method.

func (*MockResource) GetTimeSource added in v1.2.10 

func (m *MockResource) GetTimeSource() clock.TimeSource

GetTimeSource mocks base method.

func (*MockResource) GetVisibilityManager added in v1.2.10 

func (m *MockResource) GetVisibilityManager() persistence.VisibilityManager

GetVisibilityManager mocks base method.

func (*MockResource) Start added in v1.2.10 

func (m *MockResource) Start()

Start mocks base method.

func (*MockResource) Stop added in v1.2.10 

func (m *MockResource) Stop()

Stop mocks base method.

type MockResourceMockRecorder added in v1.2.10 

type MockResourceMockRecorder struct {
	// contains filtered or unexported fields
}

MockResourceMockRecorder is the mock recorder for MockResource.

func (*MockResourceMockRecorder) GetArchivalMetadata added in v1.2.10 

func (mr *MockResourceMockRecorder) GetArchivalMetadata() *gomock.Call

GetArchivalMetadata indicates an expected call of GetArchivalMetadata.

func (*MockResourceMockRecorder) GetArchiverProvider added in v1.2.10 

func (mr *MockResourceMockRecorder) GetArchiverProvider() *gomock.Call

GetArchiverProvider indicates an expected call of GetArchiverProvider.

func (*MockResourceMockRecorder) GetAsyncWorkflowQueueProvider added in v1.2.10 

func (mr *MockResourceMockRecorder) GetAsyncWorkflowQueueProvider() *gomock.Call

GetAsyncWorkflowQueueProvider indicates an expected call of GetAsyncWorkflowQueueProvider.

func (*MockResourceMockRecorder) GetBlobstoreClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetBlobstoreClient() *gomock.Call

GetBlobstoreClient indicates an expected call of GetBlobstoreClient.

func (*MockResourceMockRecorder) GetClientBean added in v1.2.10 

func (mr *MockResourceMockRecorder) GetClientBean() *gomock.Call

GetClientBean indicates an expected call of GetClientBean.

func (*MockResourceMockRecorder) GetClusterMetadata added in v1.2.10 

func (mr *MockResourceMockRecorder) GetClusterMetadata() *gomock.Call

GetClusterMetadata indicates an expected call of GetClusterMetadata.

func (*MockResourceMockRecorder) GetDispatcher added in v1.2.10 

func (mr *MockResourceMockRecorder) GetDispatcher() *gomock.Call

GetDispatcher indicates an expected call of GetDispatcher.

func (*MockResourceMockRecorder) GetDomainCache added in v1.2.10 

func (mr *MockResourceMockRecorder) GetDomainCache() *gomock.Call

GetDomainCache indicates an expected call of GetDomainCache.

func (*MockResourceMockRecorder) GetDomainManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetDomainManager() *gomock.Call

GetDomainManager indicates an expected call of GetDomainManager.

func (*MockResourceMockRecorder) GetDomainMetricsScopeCache added in v1.2.10 

func (mr *MockResourceMockRecorder) GetDomainMetricsScopeCache() *gomock.Call

GetDomainMetricsScopeCache indicates an expected call of GetDomainMetricsScopeCache.

func (*MockResourceMockRecorder) GetDomainReplicationQueue added in v1.2.10 

func (mr *MockResourceMockRecorder) GetDomainReplicationQueue() *gomock.Call

GetDomainReplicationQueue indicates an expected call of GetDomainReplicationQueue.

func (*MockResourceMockRecorder) GetEventCache added in v1.2.10 

func (mr *MockResourceMockRecorder) GetEventCache() *gomock.Call

GetEventCache indicates an expected call of GetEventCache.

func (*MockResourceMockRecorder) GetExecutionManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetExecutionManager(arg0 interface{}) *gomock.Call

GetExecutionManager indicates an expected call of GetExecutionManager.

func (*MockResourceMockRecorder) GetFrontendClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetFrontendClient() *gomock.Call

GetFrontendClient indicates an expected call of GetFrontendClient.

func (*MockResourceMockRecorder) GetFrontendRawClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetFrontendRawClient() *gomock.Call

GetFrontendRawClient indicates an expected call of GetFrontendRawClient.

func (*MockResourceMockRecorder) GetHistoryClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetHistoryClient() *gomock.Call

GetHistoryClient indicates an expected call of GetHistoryClient.

func (*MockResourceMockRecorder) GetHistoryManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetHistoryManager() *gomock.Call

GetHistoryManager indicates an expected call of GetHistoryManager.

func (*MockResourceMockRecorder) GetHistoryRawClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetHistoryRawClient() *gomock.Call

GetHistoryRawClient indicates an expected call of GetHistoryRawClient.

func (*MockResourceMockRecorder) GetHostInfo added in v1.2.10 

func (mr *MockResourceMockRecorder) GetHostInfo() *gomock.Call

GetHostInfo indicates an expected call of GetHostInfo.

func (*MockResourceMockRecorder) GetHostName added in v1.2.10 

func (mr *MockResourceMockRecorder) GetHostName() *gomock.Call

GetHostName indicates an expected call of GetHostName.

func (*MockResourceMockRecorder) GetIsolationGroupState added in v1.2.10 

func (mr *MockResourceMockRecorder) GetIsolationGroupState() *gomock.Call

GetIsolationGroupState indicates an expected call of GetIsolationGroupState.

func (*MockResourceMockRecorder) GetIsolationGroupStore added in v1.2.10 

func (mr *MockResourceMockRecorder) GetIsolationGroupStore() *gomock.Call

GetIsolationGroupStore indicates an expected call of GetIsolationGroupStore.

func (*MockResourceMockRecorder) GetLogger added in v1.2.10 

func (mr *MockResourceMockRecorder) GetLogger() *gomock.Call

GetLogger indicates an expected call of GetLogger.

func (*MockResourceMockRecorder) GetMatchingClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetMatchingClient() *gomock.Call

GetMatchingClient indicates an expected call of GetMatchingClient.

func (*MockResourceMockRecorder) GetMatchingRawClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetMatchingRawClient() *gomock.Call

GetMatchingRawClient indicates an expected call of GetMatchingRawClient.

func (*MockResourceMockRecorder) GetMembershipResolver added in v1.2.10 

func (mr *MockResourceMockRecorder) GetMembershipResolver() *gomock.Call

GetMembershipResolver indicates an expected call of GetMembershipResolver.

func (*MockResourceMockRecorder) GetMessagingClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetMessagingClient() *gomock.Call

GetMessagingClient indicates an expected call of GetMessagingClient.

func (*MockResourceMockRecorder) GetMetricsClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetMetricsClient() *gomock.Call

GetMetricsClient indicates an expected call of GetMetricsClient.

func (*MockResourceMockRecorder) GetPartitioner added in v1.2.10 

func (mr *MockResourceMockRecorder) GetPartitioner() *gomock.Call

GetPartitioner indicates an expected call of GetPartitioner.

func (*MockResourceMockRecorder) GetPayloadSerializer added in v1.2.10 

func (mr *MockResourceMockRecorder) GetPayloadSerializer() *gomock.Call

GetPayloadSerializer indicates an expected call of GetPayloadSerializer.

func (*MockResourceMockRecorder) GetPersistenceBean added in v1.2.10 

func (mr *MockResourceMockRecorder) GetPersistenceBean() *gomock.Call

GetPersistenceBean indicates an expected call of GetPersistenceBean.

func (*MockResourceMockRecorder) GetRatelimiterAggregatorsClient added in v1.2.12 

func (mr *MockResourceMockRecorder) GetRatelimiterAggregatorsClient() *gomock.Call

GetRatelimiterAggregatorsClient indicates an expected call of GetRatelimiterAggregatorsClient.

func (*MockResourceMockRecorder) GetRatelimiterAlgorithm added in v1.2.12 

func (mr *MockResourceMockRecorder) GetRatelimiterAlgorithm() *gomock.Call

GetRatelimiterAlgorithm indicates an expected call of GetRatelimiterAlgorithm.

func (*MockResourceMockRecorder) GetRemoteAdminClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetRemoteAdminClient(cluster interface{}) *gomock.Call

GetRemoteAdminClient indicates an expected call of GetRemoteAdminClient.

func (*MockResourceMockRecorder) GetRemoteFrontendClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetRemoteFrontendClient(cluster interface{}) *gomock.Call

GetRemoteFrontendClient indicates an expected call of GetRemoteFrontendClient.

func (*MockResourceMockRecorder) GetSDKClient added in v1.2.10 

func (mr *MockResourceMockRecorder) GetSDKClient() *gomock.Call

GetSDKClient indicates an expected call of GetSDKClient.

func (*MockResourceMockRecorder) GetServiceName added in v1.2.10 

func (mr *MockResourceMockRecorder) GetServiceName() *gomock.Call

GetServiceName indicates an expected call of GetServiceName.

func (*MockResourceMockRecorder) GetShardManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetShardManager() *gomock.Call

GetShardManager indicates an expected call of GetShardManager.

func (*MockResourceMockRecorder) GetTaskManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetTaskManager() *gomock.Call

GetTaskManager indicates an expected call of GetTaskManager.

func (*MockResourceMockRecorder) GetThrottledLogger added in v1.2.10 

func (mr *MockResourceMockRecorder) GetThrottledLogger() *gomock.Call

GetThrottledLogger indicates an expected call of GetThrottledLogger.

func (*MockResourceMockRecorder) GetTimeSource added in v1.2.10 

func (mr *MockResourceMockRecorder) GetTimeSource() *gomock.Call

GetTimeSource indicates an expected call of GetTimeSource.

func (*MockResourceMockRecorder) GetVisibilityManager added in v1.2.10 

func (mr *MockResourceMockRecorder) GetVisibilityManager() *gomock.Call

GetVisibilityManager indicates an expected call of GetVisibilityManager.

func (*MockResourceMockRecorder) Start added in v1.2.10 

func (mr *MockResourceMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockResourceMockRecorder) Stop added in v1.2.10 

func (mr *MockResourceMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type Resource 

type Resource interface {
	resource.Resource
	GetEventCache() events.Cache
	GetRatelimiterAlgorithm() algorithm.RequestWeighted
}

Resource is the interface which expose common history resources

func New 

func New(
	params *resource.Params,
	serviceName string,
	config *config.Config,
) (historyResource Resource, retError error)

New create a new resource containing common history dependencies

type Test 

type Test struct {
	*resource.Test
	EventCache *events.MockCache
	// contains filtered or unexported fields
}

Test is the test implementation used for testing

func NewTest 

func NewTest(
	t *testing.T,
	controller *gomock.Controller,
	serviceMetricsIndex metrics.ServiceIdx,
) *Test

NewTest returns a new test resource instance

func (*Test) GetEventCache 

func (s *Test) GetEventCache() events.Cache

GetEventCache for testing

func (*Test) GetRatelimiterAlgorithm added in v1.2.12 

func (s *Test) GetRatelimiterAlgorithm() algorithm.RequestWeighted

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.