resource

package
v1.14.2 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2022 License: MIT Imports: 44 Imported by: 0

Documentation

Overview

Package resource is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var HostInfoProviderModule = fx.Options(
	fx.Provide(NewHostInfoProvider),
	fx.Invoke(HostInfoProviderLifetimeHooks),
)
View Source 
var Module = fx.Options(
	persistenceClient.Module,
	fx.Provide(SnTaggedLoggerProvider),
	fx.Provide(ThrottledLoggerProvider),
	fx.Provide(PersistenceConfigProvider),
	fx.Provide(MetricsScopeProvider),
	fx.Provide(HostNameProvider),
	fx.Provide(ServiceNameProvider),
	fx.Provide(TimeSourceProvider),
	fx.Provide(cluster.NewMetadataFromConfig),
	fx.Provide(MetricsClientProvider),
	fx.Provide(SearchAttributeProviderProvider),
	fx.Provide(SearchAttributeManagerProvider),
	fx.Provide(NamespaceRegistryProvider),
	namespace.RegistryLifetimeHooksModule,
	fx.Provide(serialization.NewSerializer),
	fx.Provide(ArchivalMetadataProvider),
	fx.Provide(ArchiverProviderProvider),
	fx.Provide(HistoryBootstrapContainerProvider),
	fx.Provide(VisibilityBootstrapContainerProvider),
	fx.Provide(MembershipFactoryProvider),
	fx.Provide(MembershipMonitorProvider),
	membership.MonitorLifetimeHooksModule,
	fx.Provide(ClientFactoryProvider),
	fx.Provide(ClientBeanProvider),
	sdk.Module,
	fx.Provide(SdkClientFactoryProvider),
	fx.Provide(FrontedClientProvider),
	fx.Provide(PersistenceFaultInjectionFactoryProvider),
	fx.Provide(GrpcListenerProvider),
	fx.Provide(InstanceIDProvider),
	fx.Provide(RingpopChannelProvider),
	fx.Invoke(RingpopChannelLifetimeHooks),
	fx.Provide(RuntimeMetricsReporterProvider),
	metrics.RuntimeMetricsReporterLifetimeHooksModule,
	fx.Provide(HistoryClientProvider),
	fx.Provide(MatchingRawClientProvider),
	fx.Provide(MatchingClientProvider),
	HostInfoProviderModule,
	fx.Invoke(RegisterBootstrapContainer),
)

Functions

func ArchivalMetadataProvider added in v1.13.0 

func ArchivalMetadataProvider(params *BootstrapParams) archiver.ArchivalMetadata

func ArchiverProviderProvider added in v1.13.0 

func ArchiverProviderProvider(params *BootstrapParams) provider.ArchiverProvider

func ClientBeanProvider added in v1.13.0 

func ClientBeanProvider(
	clientFactory client.Factory,
	clusterMetadata cluster.Metadata,
) (client.Bean, error)

func ClientFactoryProvider added in v1.13.0 

func ClientFactoryProvider(
	factoryProvider client.FactoryProvider,
	rpcFactory common.RPCFactory,
	membershipMonitor membership.Monitor,
	metricsClient metrics.Client,
	dynamicCollection *dynamicconfig.Collection,
	persistenceConfig *config.Persistence,
	logger SnTaggedLogger,
) client.Factory

func FrontedClientProvider added in v1.13.0 

func FrontedClientProvider(clientBean client.Bean) workflowservice.WorkflowServiceClient

func GrpcListenerProvider added in v1.13.0 

func GrpcListenerProvider(factory common.RPCFactory) net.Listener

func HistoryBootstrapContainerProvider added in v1.13.0 

func HistoryBootstrapContainerProvider(
	logger SnTaggedLogger,
	metricsClient metrics.Client,
	clusterMetadata cluster.Metadata,
	executionManager persistence.ExecutionManager,
) *archiver.HistoryBootstrapContainer

func HistoryClientProvider added in v1.14.0 

func HistoryClientProvider(clientBean client.Bean) historyservice.HistoryServiceClient

func HostInfoProviderLifetimeHooks added in v1.14.0 

func HostInfoProviderLifetimeHooks(
	lc fx.Lifecycle,
	provider HostInfoProvider,
)

func MembershipMonitorProvider added in v1.13.0 

func MembershipMonitorProvider(membershipFactory MembershipMonitorFactory) (membership.Monitor, error)

TODO: Seems that this factory mostly handles singleton logic. We should be able to handle it via IOC.

func MetricsClientProvider added in v1.13.0 

func MetricsClientProvider(params *BootstrapParams) metrics.Client

func MetricsScopeProvider added in v1.13.0 

func MetricsScopeProvider(params *BootstrapParams) tally.Scope

func NamespaceRegistryProvider added in v1.14.0 

func NamespaceRegistryProvider(
	logger SnTaggedLogger,
	metricsClient metrics.Client,
	clusterMetadata cluster.Metadata,
	metadataManager persistence.MetadataManager,
) namespace.Registry

func PersistenceConfigProvider added in v1.13.0 

func PersistenceConfigProvider(params *BootstrapParams) *config.Persistence

func PersistenceFaultInjectionFactoryProvider added in v1.13.0 

func PersistenceFaultInjectionFactoryProvider(factory persistenceClient.Factory) *persistenceClient.FaultInjectionDataStoreFactory

func RegisterBootstrapContainer added in v1.13.0 

func RegisterBootstrapContainer(
	archiverProvider provider.ArchiverProvider,
	serviceName ServiceName,
	visibilityArchiverBootstrapContainer *archiver.VisibilityBootstrapContainer,
	historyArchiverBootstrapContainer *archiver.HistoryBootstrapContainer,
) error

func RingpopChannelLifetimeHooks added in v1.14.0 

func RingpopChannelLifetimeHooks(
	lc fx.Lifecycle,
	ch *tchannel.Channel,
)

func RingpopChannelProvider added in v1.13.0 

func RingpopChannelProvider(rpcFactory common.RPCFactory) *tchannel.Channel

func RuntimeMetricsReporterProvider added in v1.13.0 

func RuntimeMetricsReporterProvider(
	metricsScope tally.Scope,
	logger SnTaggedLogger,
	instanceID InstanceID,
) *metrics.RuntimeMetricsReporter

func SdkClientFactoryProvider added in v1.14.0 

func SdkClientFactoryProvider(params *BootstrapParams) sdk.ClientFactory

TODO (alex): move this to `sdk` package after BootstrapParams removal.

func SearchAttributeManagerProvider added in v1.13.0 

func SearchAttributeManagerProvider(
	timeSource clock.TimeSource,
	cmMgr persistence.ClusterMetadataManager,
) searchattribute.Manager

func SearchAttributeProviderProvider added in v1.13.0 

func SearchAttributeProviderProvider(
	timeSource clock.TimeSource,
	cmMgr persistence.ClusterMetadataManager,
) searchattribute.Provider

func TimeSourceProvider added in v1.13.0 

func TimeSourceProvider() clock.TimeSource

func VisibilityBootstrapContainerProvider added in v1.13.0 

func VisibilityBootstrapContainerProvider(
	logger SnTaggedLogger,
	metricsClient metrics.Client,
	clusterMetadata cluster.Metadata,
) *archiver.VisibilityBootstrapContainer

Types

type BootstrapParams 

type BootstrapParams struct {
	Name            string
	InstanceID      string
	ThrottledLogger log.Logger
	NamespaceLogger log.Logger

	MetricsScope                 tally.Scope
	MembershipFactoryInitializer MembershipFactoryInitializerFunc
	RPCFactory                   common.RPCFactory
	ClientFactoryProvider        client.FactoryProvider
	PersistenceConfig            config.Persistence
	ClusterMetadataConfig        *cluster.Config
	ReplicatorConfig             config.Replicator
	ServerMetricsReporter        metrics.Reporter
	SDKMetricsReporter           metrics.Reporter
	MetricsClient                metrics.Client
	DCRedirectionPolicy          config.DCRedirectionPolicy
	SdkClientFactory             sdk.ClientFactory
	ArchivalMetadata             archiver.ArchivalMetadata
	ArchiverProvider             provider.ArchiverProvider
}

BootstrapParams holds the set of parameters needed to bootstrap a service

type CachingHostInfoProvider added in v1.14.0 

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

func (*CachingHostInfoProvider) HostInfo added in v1.14.0 

func (hip *CachingHostInfoProvider) HostInfo() *membership.HostInfo

func (*CachingHostInfoProvider) Start added in v1.14.0 

func (hip *CachingHostInfoProvider) Start() error

type HostInfoProvider added in v1.14.0 

type HostInfoProvider interface {
	Start() error
	HostInfo() *membership.HostInfo
}

func NewHostInfoProvider added in v1.14.0 

func NewHostInfoProvider(membershipMonitor membership.Monitor) HostInfoProvider

type HostName added in v1.13.0 

type HostName string

func HostNameProvider added in v1.13.0 

func HostNameProvider() (HostName, error)

type Impl 

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

Impl contains all common resources shared across frontend / matching / history / worker

func New 

func New(
	pLogger log.Logger,
	params *BootstrapParams,
	serviceName string,
	dcClient dynamicconfig.Client,
	persistenceMaxQPS dynamicconfig.IntPropertyFn,
	persistenceGlobalMaxQPS dynamicconfig.IntPropertyFn,
	throttledLoggerMaxRPS dynamicconfig.IntPropertyFn,
	datastoreFactory persistenceClient.AbstractDataStoreFactory,
	persistenceServiceResolver resolver.ServiceResolver,
	searchAttributesMapper searchattribute.Mapper,
) (impl *Impl, retError error)

New create a new resource containing common dependencies

func (*Impl) GetArchivalMetadata 

func (h *Impl) GetArchivalMetadata() archiver.ArchivalMetadata

GetArchivalMetadata return archival metadata

func (*Impl) GetArchiverProvider 

func (h *Impl) GetArchiverProvider() provider.ArchiverProvider

GetArchiverProvider return archival provider

func (*Impl) GetClientBean 

func (h *Impl) GetClientBean() client.Bean

GetClientBean return RPC client bean

func (*Impl) GetClientFactory added in v1.14.0 

func (h *Impl) GetClientFactory() client.Factory

GetClientFactory return RPC client factory

func (*Impl) GetClusterMetadata 

func (h *Impl) GetClusterMetadata() cluster.Metadata

GetClusterMetadata return cluster metadata

func (*Impl) GetClusterMetadataManager 

func (h *Impl) GetClusterMetadataManager() persistence.ClusterMetadataManager

GetClusterMetadataManager return metadata manager

func (*Impl) GetExecutionManager 

func (h *Impl) GetExecutionManager() persistence.ExecutionManager

GetExecutionManager return execution manager

func (*Impl) GetFaultInjection added in v1.13.0 

func (h *Impl) GetFaultInjection() *persistenceClient.FaultInjectionDataStoreFactory

func (*Impl) GetFrontendClient 

func (h *Impl) GetFrontendClient() workflowservice.WorkflowServiceClient

GetFrontendClient return frontend client with retry policy

func (*Impl) GetFrontendServiceResolver 

func (h *Impl) GetFrontendServiceResolver() membership.ServiceResolver

GetFrontendServiceResolver return frontend service resolver

func (*Impl) GetGRPCListener 

func (h *Impl) GetGRPCListener() net.Listener

GetGRPCListener return GRPC listener, used for registering handlers

func (*Impl) GetHistoryClient 

func (h *Impl) GetHistoryClient() historyservice.HistoryServiceClient

GetHistoryClient return history client with retry policy

func (*Impl) GetHistoryRawClient 

func (h *Impl) GetHistoryRawClient() historyservice.HistoryServiceClient

GetHistoryRawClient return history client without retry policy

func (*Impl) GetHistoryServiceResolver 

func (h *Impl) GetHistoryServiceResolver() membership.ServiceResolver

GetHistoryServiceResolver return history service resolver

func (*Impl) GetHostInfo 

func (h *Impl) GetHostInfo() *membership.HostInfo

GetHostInfo return host info

func (*Impl) GetHostName 

func (h *Impl) GetHostName() string

GetHostName return host name

func (*Impl) GetLogger 

func (h *Impl) GetLogger() log.Logger

GetLogger return logger

func (*Impl) GetMatchingClient 

func (h *Impl) GetMatchingClient() matchingservice.MatchingServiceClient

GetMatchingClient return matching client with retry policy

func (*Impl) GetMatchingRawClient 

func (h *Impl) GetMatchingRawClient() matchingservice.MatchingServiceClient

GetMatchingRawClient return matching client without retry policy

func (*Impl) GetMatchingServiceResolver 

func (h *Impl) GetMatchingServiceResolver() membership.ServiceResolver

GetMatchingServiceResolver return matching service resolver

func (*Impl) GetMembershipMonitor 

func (h *Impl) GetMembershipMonitor() membership.Monitor

GetMembershipMonitor return the membership monitor

func (*Impl) GetMetadataManager 

func (h *Impl) GetMetadataManager() persistence.MetadataManager

GetMetadataManager return metadata manager

func (*Impl) GetMetricsClient 

func (h *Impl) GetMetricsClient() metrics.Client

GetMetricsClient return metrics client

func (*Impl) GetNamespaceRegistry added in v1.13.0 

func (h *Impl) GetNamespaceRegistry() namespace.Registry

GetNamespaceRegistry return namespace cache

func (*Impl) GetNamespaceReplicationQueue 

func (h *Impl) GetNamespaceReplicationQueue() persistence.NamespaceReplicationQueue

GetNamespaceReplicationQueue return namespace replication queue

func (*Impl) GetPayloadSerializer 

func (h *Impl) GetPayloadSerializer() serialization.Serializer

GetPayloadSerializer return binary payload serializer

func (*Impl) GetPersistenceBean 

func (h *Impl) GetPersistenceBean() persistenceClient.Bean

GetPersistenceBean return persistence bean

func (*Impl) GetRemoteAdminClient 

func (h *Impl) GetRemoteAdminClient(
	cluster string,
) adminservice.AdminServiceClient

GetRemoteAdminClient return remote admin client for given cluster name

func (*Impl) GetRemoteFrontendClient 

func (h *Impl) GetRemoteFrontendClient(
	cluster string,
) workflowservice.WorkflowServiceClient

GetRemoteFrontendClient return remote frontend client for given cluster name

func (*Impl) GetSDKClientFactory added in v1.14.0 

func (h *Impl) GetSDKClientFactory() sdk.ClientFactory

GetSDKClientFactory return sdk client

func (*Impl) GetSearchAttributesManager added in v1.11.0 

func (h *Impl) GetSearchAttributesManager() searchattribute.Manager

func (*Impl) GetSearchAttributesMapper added in v1.12.1 

func (h *Impl) GetSearchAttributesMapper() searchattribute.Mapper

func (*Impl) GetSearchAttributesProvider added in v1.10.0 

func (h *Impl) GetSearchAttributesProvider() searchattribute.Provider

func (*Impl) GetServiceName 

func (h *Impl) GetServiceName() string

GetServiceName return service name

func (*Impl) GetShardManager 

func (h *Impl) GetShardManager() persistence.ShardManager

GetShardManager return shard manager

func (*Impl) GetTaskManager 

func (h *Impl) GetTaskManager() persistence.TaskManager

GetTaskManager return task manager

func (*Impl) GetThrottledLogger 

func (h *Impl) GetThrottledLogger() log.Logger

GetThrottledLogger return throttled logger

func (*Impl) GetTimeSource 

func (h *Impl) GetTimeSource() clock.TimeSource

GetTimeSource return time source

func (*Impl) GetWorkerServiceResolver 

func (h *Impl) GetWorkerServiceResolver() membership.ServiceResolver

GetWorkerServiceResolver return worker service resolver

func (*Impl) Start 

func (h *Impl) Start()

Start start all resources

func (*Impl) Stop 

func (h *Impl) Stop()

Stop stops all resources

type InstanceID added in v1.13.0 

type InstanceID string

func InstanceIDProvider added in v1.13.0 

func InstanceIDProvider(params *BootstrapParams) InstanceID

type MatchingClient added in v1.14.0 

type MatchingClient matchingservice.MatchingServiceClient

func MatchingClientProvider added in v1.14.0 

func MatchingClientProvider(matchingRawClient MatchingRawClient) MatchingClient

type MatchingRawClient added in v1.14.0 

type MatchingRawClient matchingservice.MatchingServiceClient

func MatchingRawClientProvider added in v1.14.0 

func MatchingRawClientProvider(clientBean client.Bean, namespaceRegistry namespace.Registry) (
	MatchingRawClient,
	error,
)

type MembershipFactoryInitializerFunc 

type MembershipFactoryInitializerFunc func(persistenceBean persistenceClient.Bean, logger log.Logger) (MembershipMonitorFactory, error)

MembershipFactoryInitializerFunc is used for deferred initialization of the MembershipFactory to allow for the PersistenceBean to be constructed further downstream.

type MembershipMonitorFactory 

type MembershipMonitorFactory interface {
	// GetMembershipMonitor return a membership monitor
	GetMembershipMonitor() (membership.Monitor, error)
}

MembershipMonitorFactory provides a bootstrapped membership monitor

func MembershipFactoryProvider added in v1.13.0 

func MembershipFactoryProvider(
	params *BootstrapParams,
	persistenceBean persistenceClient.Bean,
	logger SnTaggedLogger,
) (MembershipMonitorFactory, error)

type MockHostInfoProvider added in v1.14.0 

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

MockHostInfoProvider is a mock of HostInfoProvider interface.

func NewMockHostInfoProvider added in v1.14.0 

func NewMockHostInfoProvider(ctrl *gomock.Controller) *MockHostInfoProvider

NewMockHostInfoProvider creates a new mock instance.

func (*MockHostInfoProvider) EXPECT added in v1.14.0 

func (m *MockHostInfoProvider) EXPECT() *MockHostInfoProviderMockRecorder

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

func (*MockHostInfoProvider) HostInfo added in v1.14.0 

func (m *MockHostInfoProvider) HostInfo() *membership.HostInfo

HostInfo mocks base method.

func (*MockHostInfoProvider) Start added in v1.14.0 

func (m *MockHostInfoProvider) Start() error

Start mocks base method.

type MockHostInfoProviderMockRecorder added in v1.14.0 

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

MockHostInfoProviderMockRecorder is the mock recorder for MockHostInfoProvider.

func (*MockHostInfoProviderMockRecorder) HostInfo added in v1.14.0 

func (mr *MockHostInfoProviderMockRecorder) HostInfo() *gomock.Call

HostInfo indicates an expected call of HostInfo.

func (*MockHostInfoProviderMockRecorder) Start added in v1.14.0 

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

Start indicates an expected call of Start.

type Resource 

type Resource interface {
	common.Daemon

	GetServiceName() string
	GetHostName() string
	GetHostInfo() *membership.HostInfo
	GetArchivalMetadata() archiver.ArchivalMetadata
	GetClusterMetadata() cluster.Metadata
	GetSearchAttributesProvider() searchattribute.Provider
	GetSearchAttributesManager() searchattribute.Manager
	GetSearchAttributesMapper() searchattribute.Mapper

	GetNamespaceRegistry() namespace.Registry
	GetTimeSource() clock.TimeSource
	GetPayloadSerializer() serialization.Serializer
	GetMetricsClient() metrics.Client
	GetArchiverProvider() provider.ArchiverProvider

	GetMembershipMonitor() membership.Monitor
	GetFrontendServiceResolver() membership.ServiceResolver
	GetMatchingServiceResolver() membership.ServiceResolver
	GetHistoryServiceResolver() membership.ServiceResolver
	GetWorkerServiceResolver() membership.ServiceResolver

	GetSDKClientFactory() sdk.ClientFactory
	GetFrontendClient() workflowservice.WorkflowServiceClient
	GetMatchingRawClient() matchingservice.MatchingServiceClient
	GetMatchingClient() matchingservice.MatchingServiceClient
	GetHistoryRawClient() historyservice.HistoryServiceClient
	GetHistoryClient() historyservice.HistoryServiceClient
	GetRemoteAdminClient(cluster string) adminservice.AdminServiceClient
	GetRemoteFrontendClient(cluster string) workflowservice.WorkflowServiceClient
	GetClientBean() client.Bean
	GetClientFactory() client.Factory

	GetMetadataManager() persistence.MetadataManager
	GetClusterMetadataManager() persistence.ClusterMetadataManager
	GetTaskManager() persistence.TaskManager
	GetNamespaceReplicationQueue() persistence.NamespaceReplicationQueue
	GetShardManager() persistence.ShardManager
	GetExecutionManager() persistence.ExecutionManager
	GetPersistenceBean() persistenceClient.Bean
	GetFaultInjection() *persistenceClient.FaultInjectionDataStoreFactory

	GetLogger() log.Logger
	GetThrottledLogger() log.Logger

	// for registering handlers
	GetGRPCListener() net.Listener
}

Resource is the interface which expose common resources

type ServiceName added in v1.13.0 

type ServiceName string

func ServiceNameProvider added in v1.13.0 

func ServiceNameProvider(params *BootstrapParams) ServiceName

type SnTaggedLogger added in v1.13.0 

type SnTaggedLogger log.Logger

func SnTaggedLoggerProvider added in v1.13.0 

func SnTaggedLoggerProvider(logger log.Logger, sn ServiceName) SnTaggedLogger

type Test 

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

	NamespaceCache    *namespace.MockRegistry
	TimeSource        clock.TimeSource
	PayloadSerializer serialization.Serializer
	MetricsClient     metrics.Client
	ArchivalMetadata  *archiver.MockArchivalMetadata
	ArchiverProvider  *provider.MockArchiverProvider

	MembershipMonitor       *membership.MockMonitor
	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

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

	Logger log.Logger
}

Test is the test implementation used for testing

func NewTest 

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

NewTest returns a new test resource instance

func (*Test) GetArchivalMetadata 

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

GetArchivalMetadata for testing

func (*Test) GetArchiverProvider 

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

GetArchiverProvider for testing

func (*Test) GetClientBean 

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

GetClientBean for testing

func (*Test) GetClientFactory added in v1.14.0 

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

GetClientFactory for testing

func (*Test) GetClusterMetadata 

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

GetClusterMetadata for testing

func (*Test) GetClusterMetadataManager added in v1.1.0 

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

GetClusterMetadata for testing

func (*Test) GetExecutionManager 

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

GetExecutionManager for testing

func (*Test) GetFaultInjection added in v1.13.0 

func (h *Test) GetFaultInjection() *persistenceClient.FaultInjectionDataStoreFactory

func (*Test) GetFrontendClient 

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

GetFrontendClient for testing

func (*Test) GetFrontendServiceResolver 

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

GetFrontendServiceResolver for testing

func (*Test) GetGRPCListener 

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

GetGRPCListener for testing

func (*Test) GetHistoryClient 

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

GetHistoryClient for testing

func (*Test) GetHistoryRawClient 

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

GetHistoryRawClient for testing

func (*Test) GetHistoryServiceResolver 

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

GetHistoryServiceResolver for testing

func (*Test) GetHostInfo 

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

GetHostInfo for testing

func (*Test) GetHostName 

func (s *Test) GetHostName() string

GetHostName for testing

func (*Test) GetLogger 

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

GetLogger for testing

func (*Test) GetMatchingClient 

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

GetMatchingClient for testing

func (*Test) GetMatchingRawClient 

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

GetMatchingRawClient for testing

func (*Test) GetMatchingServiceResolver 

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

GetMatchingServiceResolver for testing

func (*Test) GetMembershipMonitor 

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

GetMembershipMonitor for testing

func (*Test) GetMetadataManager 

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

GetMetadataManager for testing

func (*Test) GetMetricsClient 

func (s *Test) GetMetricsClient() metrics.Client

GetMetricsClient for testing

func (*Test) GetNamespaceRegistry added in v1.13.0 

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

GetNamespaceRegistry for testing

func (*Test) GetNamespaceReplicationQueue 

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

GetNamespaceReplicationQueue for testing

func (*Test) GetPayloadSerializer 

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

GetPayloadSerializer for testing

func (*Test) GetPersistenceBean 

func (s *Test) GetPersistenceBean() persistenceClient.Bean

GetPersistenceBean for testing

func (*Test) GetRemoteAdminClient 

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

GetRemoteAdminClient for testing

func (*Test) GetRemoteFrontendClient 

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

GetRemoteFrontendClient for testing

func (*Test) GetSDKClientFactory added in v1.14.0 

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

GetSDKClientFactory for testing

func (*Test) GetSearchAttributesManager added in v1.11.0 

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

func (*Test) GetSearchAttributesMapper added in v1.12.1 

func (h *Test) GetSearchAttributesMapper() searchattribute.Mapper

func (*Test) GetSearchAttributesProvider added in v1.10.0 

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

func (*Test) GetServiceName 

func (s *Test) GetServiceName() string

GetServiceName for testing

func (*Test) GetShardManager 

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

GetShardManager for testing

func (*Test) GetTaskManager 

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

GetTaskManager for testing

func (*Test) GetThrottledLogger 

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

GetThrottledLogger for testing

func (*Test) GetTimeSource 

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

GetTimeSource for testing

func (*Test) GetWorkerServiceResolver 

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

GetWorkerServiceResolver for testing

func (*Test) RefreshNamespaceCache added in v1.13.0 

func (h *Test) RefreshNamespaceCache()

func (*Test) Start 

func (s *Test) Start()

Start for testing

func (*Test) Stop 

func (s *Test) Stop()

Stop for testing

type ThrottledLogger added in v1.13.0 

type ThrottledLogger log.Logger

func ThrottledLoggerProvider added in v1.13.0 

func ThrottledLoggerProvider(
	logger SnTaggedLogger,
	fn ThrottledLoggerRpsFn,
) ThrottledLogger

type ThrottledLoggerRpsFn added in v1.13.0 

type ThrottledLoggerRpsFn quotas.RateFn

type VisibilityManagerInitializer 

type VisibilityManagerInitializer func(
	persistenceBean persistenceClient.Bean,
	searchAttributesProvider searchattribute.Provider,
	logger log.Logger,
) (manager.VisibilityManager, error)

VisibilityManagerInitializer is the function each service should implement for visibility manager initialization

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.
JackTT - Gopher 🇻🇳