resourcetest

Documentation

Index

• type Test
  • func NewTest(controller *gomock.Controller, serviceName primitives.ServiceName) *Test
  • func (t *Test) GetArchivalMetadata() archiver.ArchivalMetadata
  • func (t *Test) GetArchiverProvider() provider.ArchiverProvider
  • func (t *Test) GetClientBean() client.Bean
  • func (t *Test) GetClientFactory() client.Factory
  • func (t *Test) GetClusterMetadata() cluster.Metadata
  • func (t *Test) GetClusterMetadataManager() persistence.ClusterMetadataManager
  • func (t *Test) GetExecutionManager() persistence.ExecutionManager
  • func (t *Test) GetFrontendClient() workflowservice.WorkflowServiceClient
  • func (t *Test) GetFrontendServiceResolver() membership.ServiceResolver
  • func (t *Test) GetGRPCListener() net.Listener
  • func (t *Test) GetHistoryClient() historyservice.HistoryServiceClient
  • func (t *Test) GetHistoryRawClient() historyservice.HistoryServiceClient
  • func (t *Test) GetHistoryServiceResolver() membership.ServiceResolver
  • func (t *Test) GetHostInfo() membership.HostInfo
  • func (t *Test) GetHostInfoProvider() membership.HostInfoProvider
  • func (t *Test) GetHostName() string
  • func (t *Test) GetLogger() log.Logger
  • func (t *Test) GetMatchingClient() matchingservice.MatchingServiceClient
  • func (t *Test) GetMatchingRawClient() matchingservice.MatchingServiceClient
  • func (t *Test) GetMatchingServiceResolver() membership.ServiceResolver
  • func (t *Test) GetMembershipMonitor() membership.Monitor
  • func (t *Test) GetMetadataManager() persistence.MetadataManager
  • func (t *Test) GetMetricsHandler() metrics.Handler
  • func (t *Test) GetNamespaceRegistry() namespace.Registry
  • func (t *Test) GetNamespaceReplicationQueue() persistence.NamespaceReplicationQueue
  • func (t *Test) GetPayloadSerializer() serialization.Serializer
  • func (t *Test) GetRemoteAdminClient(cluster string) adminservice.AdminServiceClient
  • func (t *Test) GetRemoteFrontendClient(cluster string) workflowservice.WorkflowServiceClient
  • func (t *Test) GetSDKClientFactory() sdk.ClientFactory
  • func (t *Test) GetSearchAttributesManager() searchattribute.Manager
  • func (t *Test) GetSearchAttributesMapperProvider() searchattribute.MapperProvider
  • func (t *Test) GetSearchAttributesProvider() searchattribute.Provider
  • func (t *Test) GetServiceName() string
  • func (t *Test) GetShardManager() persistence.ShardManager
  • func (t *Test) GetTaskManager() persistence.TaskManager
  • func (t *Test) GetThrottledLogger() log.Logger
  • func (t *Test) GetTimeSource() clock.TimeSource
  • func (t *Test) GetVisibilityManager() manager.VisibilityManager
  • func (t *Test) GetWorkerServiceResolver() membership.ServiceResolver
  • func (t *Test) Start()
  • func (t *Test) Stop()

Types

type Test

type Test struct {
	MetricsScope                   tally.Scope
	ClusterMetadata                *cluster.MockMetadata
	SearchAttributesProvider       *searchattribute.MockProvider
	SearchAttributesManager        *searchattribute.MockManager
	SearchAttributesMapperProvider *searchattribute.MockMapperProvider

	NamespaceCache    *namespace.MockRegistry
	TimeSource        clock.TimeSource
	PayloadSerializer serialization.Serializer
	MetricsHandler    metrics.Handler
	ArchivalMetadata  archiver.MetadataMock
	ArchiverProvider  *provider.MockArchiverProvider

	MembershipMonitor       *membership.MockMonitor
	HostInfoProvider        *membership.MockHostInfoProvider
	FrontendServiceResolver *membership.MockServiceResolver
	MatchingServiceResolver *membership.MockServiceResolver
	HistoryServiceResolver  *membership.MockServiceResolver
	WorkerServiceResolver   *membership.MockServiceResolver

	SDKClientFactory     *sdk.MockClientFactory
	FrontendClient       *workflowservicemock.MockWorkflowServiceClient
	MatchingClient       *matchingservicemock.MockMatchingServiceClient
	HistoryClient        *historyservicemock.MockHistoryServiceClient
	RemoteAdminClient    *adminservicemock.MockAdminServiceClient
	RemoteFrontendClient *workflowservicemock.MockWorkflowServiceClient
	ClientBean           *client.MockBean
	ClientFactory        *client.MockFactory
	ESClient             *esclient.MockClient
	VisibilityManager    *manager.MockVisibilityManager

	MetadataMgr               *persistence.MockMetadataManager
	ClusterMetadataMgr        *persistence.MockClusterMetadataManager
	TaskMgr                   *persistence.MockTaskManager
	NamespaceReplicationQueue persistence.NamespaceReplicationQueue
	ShardMgr                  *persistence.MockShardManager
	ExecutionMgr              *persistence.MockExecutionManager

	Logger log.Logger
}

Test is the test implementation used for testing

func NewTest

func NewTest(controller *gomock.Controller, serviceName primitives.ServiceName) *Test

NewTest returns a new test resource instance

func (*Test) GetArchivalMetadata

func (t *Test) GetArchivalMetadata() archiver.ArchivalMetadata

GetArchivalMetadata for testing

func (*Test) GetArchiverProvider

func (t *Test) GetArchiverProvider() provider.ArchiverProvider

GetArchiverProvider for testing

func (*Test) GetClientBean

func (t *Test) GetClientBean() client.Bean

GetClientBean for testing

func (*Test) GetClientFactory

func (t *Test) GetClientFactory() client.Factory

GetClientFactory for testing

func (*Test) GetClusterMetadata

func (t *Test) GetClusterMetadata() cluster.Metadata

GetClusterMetadata for testing

func (*Test) GetClusterMetadataManager

func (t *Test) GetClusterMetadataManager() persistence.ClusterMetadataManager

GetClusterMetadata for testing

func (*Test) GetExecutionManager

func (t *Test) GetExecutionManager() persistence.ExecutionManager

GetExecutionManager for testing

func (*Test) GetFrontendClient

func (t *Test) GetFrontendClient() workflowservice.WorkflowServiceClient

GetFrontendClient for testing

func (*Test) GetFrontendServiceResolver

func (t *Test) GetFrontendServiceResolver() membership.ServiceResolver

GetFrontendServiceResolver for testing

func (*Test) GetGRPCListener

func (t *Test) GetGRPCListener() net.Listener

GetGRPCListener for testing

func (*Test) GetHistoryClient

func (t *Test) GetHistoryClient() historyservice.HistoryServiceClient

GetHistoryClient for testing

func (*Test) GetHistoryRawClient

func (t *Test) GetHistoryRawClient() historyservice.HistoryServiceClient

GetHistoryRawClient for testing

func (*Test) GetHistoryServiceResolver

func (t *Test) GetHistoryServiceResolver() membership.ServiceResolver

GetHistoryServiceResolver for testing

func (*Test) GetHostInfo

func (t *Test) GetHostInfo() membership.HostInfo

GetHostInfo for testing

func (*Test) GetHostInfoProvider

func (t *Test) GetHostInfoProvider() membership.HostInfoProvider

GetHostInfoProvider for testing

func (*Test) GetHostName

func (t *Test) GetHostName() string

GetHostName for testing

func (*Test) GetLogger

func (t *Test) GetLogger() log.Logger

GetLogger for testing

func (*Test) GetMatchingClient

func (t *Test) GetMatchingClient() matchingservice.MatchingServiceClient

GetMatchingClient for testing

func (*Test) GetMatchingRawClient

func (t *Test) GetMatchingRawClient() matchingservice.MatchingServiceClient

GetMatchingRawClient for testing

func (*Test) GetMatchingServiceResolver

func (t *Test) GetMatchingServiceResolver() membership.ServiceResolver

GetMatchingServiceResolver for testing

func (*Test) GetMembershipMonitor

func (t *Test) GetMembershipMonitor() membership.Monitor

GetMembershipMonitor for testing

func (*Test) GetMetadataManager

func (t *Test) GetMetadataManager() persistence.MetadataManager

GetMetadataManager for testing

func (*Test) GetMetricsHandler

func (t *Test) GetMetricsHandler() metrics.Handler

GetMetricsHandler for testing

func (*Test) GetNamespaceRegistry

func (t *Test) GetNamespaceRegistry() namespace.Registry

GetNamespaceRegistry for testing

func (*Test) GetNamespaceReplicationQueue

func (t *Test) GetNamespaceReplicationQueue() persistence.NamespaceReplicationQueue

GetNamespaceReplicationQueue for testing

func (*Test) GetPayloadSerializer

func (t *Test) GetPayloadSerializer() serialization.Serializer

GetPayloadSerializer for testing

func (*Test) GetRemoteAdminClient

func (t *Test) GetRemoteAdminClient(
	cluster string,
) adminservice.AdminServiceClient

GetRemoteAdminClient for testing

func (*Test) GetRemoteFrontendClient

func (t *Test) GetRemoteFrontendClient(
	cluster string,
) workflowservice.WorkflowServiceClient

GetRemoteFrontendClient for testing

func (*Test) GetSDKClientFactory

func (t *Test) GetSDKClientFactory() sdk.ClientFactory

GetSDKClientFactory for testing

func (*Test) GetSearchAttributesManager

func (t *Test) GetSearchAttributesManager() searchattribute.Manager

func (*Test) GetSearchAttributesMapperProvider

func (t *Test) GetSearchAttributesMapperProvider() searchattribute.MapperProvider

func (*Test) GetSearchAttributesProvider

func (t *Test) GetSearchAttributesProvider() searchattribute.Provider

func (*Test) GetServiceName

func (t *Test) GetServiceName() string

GetServiceName for testing

func (*Test) GetShardManager

func (t *Test) GetShardManager() persistence.ShardManager

GetShardManager for testing

func (*Test) GetTaskManager

func (t *Test) GetTaskManager() persistence.TaskManager

GetTaskManager for testing

func (*Test) GetThrottledLogger

func (t *Test) GetThrottledLogger() log.Logger

GetThrottledLogger for testing

func (*Test) GetTimeSource

func (t *Test) GetTimeSource() clock.TimeSource

GetTimeSource for testing

func (*Test) GetVisibilityManager

func (t *Test) GetVisibilityManager() manager.VisibilityManager

GetVisibilityManager for testing

func (*Test) GetWorkerServiceResolver

func (t *Test) GetWorkerServiceResolver() membership.ServiceResolver

GetWorkerServiceResolver for testing

func (*Test) Start

func (t *Test) Start()

Start for testing

func (*Test) Stop

func (t *Test) Stop()

Stop for testing