resource

package
v1.22.5 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2024 License: MIT Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultOptions = fx.Options(
	ringpop.Module,
	fx.Provide(RPCFactoryProvider),
	fx.Provide(ArchivalMetadataProvider),
	fx.Provide(ArchiverProviderProvider),
	fx.Provide(ThrottledLoggerProvider),
	fx.Provide(SdkClientFactoryProvider),
	fx.Provide(DCRedirectionPolicyProvider),
)
View Source 
var Module = fx.Options(
	persistenceClient.Module,
	fx.Provide(HostNameProvider),
	fx.Provide(TimeSourceProvider),
	cluster.MetadataLifetimeHooksModule,
	fx.Provide(SearchAttributeMapperProviderProvider),
	fx.Provide(SearchAttributeProviderProvider),
	fx.Provide(SearchAttributeManagerProvider),
	fx.Provide(NamespaceRegistryProvider),
	namespace.RegistryLifetimeHooksModule,
	fx.Provide(fx.Annotate(
		func(p namespace.Registry) common.Pingable { return p },
		fx.ResultTags(`group:"deadlockDetectorRoots"`),
	)),
	fx.Provide(serialization.NewSerializer),
	fx.Provide(HistoryBootstrapContainerProvider),
	fx.Provide(VisibilityBootstrapContainerProvider),
	fx.Provide(ClientFactoryProvider),
	fx.Provide(ClientBeanProvider),
	fx.Provide(FrontendClientProvider),
	fx.Provide(GrpcListenerProvider),
	fx.Provide(RuntimeMetricsReporterProvider),
	metrics.RuntimeMetricsReporterLifetimeHooksModule,
	fx.Provide(HistoryRawClientProvider),
	fx.Provide(HistoryClientProvider),
	fx.Provide(MatchingRawClientProvider),
	fx.Provide(MatchingClientProvider),
	membership.GRPCResolverModule,
	fx.Invoke(RegisterBootstrapContainer),
	fx.Provide(PersistenceConfigProvider),
	fx.Provide(health.NewServer),
	deadlock.Module,
	config.Module,
)

Module Use fx.Hook and OnStart/OnStop to manage Daemon resource lifecycle See LifetimeHooksModule for detail

Functions

func ArchivalMetadataProvider added in v1.13.0 

func ArchivalMetadataProvider(dc *dynamicconfig.Collection, cfg *config.Config) archiver.ArchivalMetadata

func ArchiverProviderProvider added in v1.13.0 

func ArchiverProviderProvider(cfg *config.Config) 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,
	metricsHandler metrics.Handler,
	dynamicCollection *dynamicconfig.Collection,
	persistenceConfig *config.Persistence,
	logger log.SnTaggedLogger,
	throttledLogger log.ThrottledLogger,
) client.Factory

func DCRedirectionPolicyProvider added in v1.16.0 

func DCRedirectionPolicyProvider(cfg *config.Config) config.DCRedirectionPolicy

func DefaultSnTaggedLoggerProvider added in v1.20.0 

func DefaultSnTaggedLoggerProvider(logger log.Logger, sn primitives.ServiceName) log.SnTaggedLogger

func FrontendClientProvider added in v1.17.0 

func FrontendClientProvider(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 log.SnTaggedLogger,
	metricsHandler metrics.Handler,
	clusterMetadata cluster.Metadata,
	executionManager persistence.ExecutionManager,
) *archiver.HistoryBootstrapContainer

func NamespaceRegistryProvider added in v1.14.0 

func NamespaceRegistryProvider(
	logger log.SnTaggedLogger,
	metricsHandler metrics.Handler,
	clusterMetadata cluster.Metadata,
	metadataManager persistence.MetadataManager,
	dynamicCollection *dynamicconfig.Collection,
) namespace.Registry

func PersistenceConfigProvider added in v1.13.0 

func PersistenceConfigProvider(persistenceConfig config.Persistence, dc *dynamicconfig.Collection) *config.Persistence

func RPCFactoryProvider added in v1.16.0 

func RPCFactoryProvider(
	cfg *config.Config,
	svcName primitives.ServiceName,
	logger log.Logger,
	tlsConfigProvider encryption.TLSConfigProvider,
	resolver membership.GRPCResolver,
	traceInterceptor telemetry.ClientTraceInterceptor,
) (common.RPCFactory, error)

func RegisterBootstrapContainer added in v1.13.0 

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

func RuntimeMetricsReporterProvider added in v1.13.0 

func RuntimeMetricsReporterProvider(
	params RuntimeMetricsReporterParams,
) *metrics.RuntimeMetricsReporter

func SdkClientFactoryProvider added in v1.14.0 

func SdkClientFactoryProvider(
	cfg *config.Config,
	tlsConfigProvider encryption.TLSConfigProvider,
	metricsHandler metrics.Handler,
	logger log.SnTaggedLogger,
	resolver membership.GRPCResolver,
	dc *dynamicconfig.Collection,
) (sdk.ClientFactory, error)

func SearchAttributeManagerProvider added in v1.13.0 

func SearchAttributeManagerProvider(
	timeSource clock.TimeSource,
	cmMgr persistence.ClusterMetadataManager,
	dynamicCollection *dynamicconfig.Collection,
) searchattribute.Manager

func SearchAttributeMapperProviderProvider added in v1.20.0 

func SearchAttributeMapperProviderProvider(
	saMapper searchattribute.Mapper,
	namespaceRegistry namespace.Registry,
	searchAttributeProvider searchattribute.Provider,
	persistenceConfig *config.Persistence,
) searchattribute.MapperProvider

func SearchAttributeProviderProvider added in v1.13.0 

func SearchAttributeProviderProvider(
	timeSource clock.TimeSource,
	cmMgr persistence.ClusterMetadataManager,
	dynamicCollection *dynamicconfig.Collection,
) searchattribute.Provider

func ThrottledLoggerProvider added in v1.13.0 

func ThrottledLoggerProvider(
	logger log.SnTaggedLogger,
	fn ThrottledLoggerRpsFn,
) log.ThrottledLogger

func TimeSourceProvider added in v1.13.0 

func TimeSourceProvider() clock.TimeSource

func VisibilityBootstrapContainerProvider added in v1.13.0 

func VisibilityBootstrapContainerProvider(
	logger log.SnTaggedLogger,
	metricsHandler metrics.Handler,
	clusterMetadata cluster.Metadata,
) *archiver.VisibilityBootstrapContainer

Types

type HistoryClient added in v1.22.0 

type HistoryClient historyservice.HistoryServiceClient

func HistoryClientProvider added in v1.14.0 

func HistoryClientProvider(historyRawClient HistoryRawClient) HistoryClient

type HistoryRawClient added in v1.22.0 

type HistoryRawClient historyservice.HistoryServiceClient

func HistoryRawClientProvider added in v1.22.0 

func HistoryRawClientProvider(clientBean client.Bean) HistoryRawClient

type HostName added in v1.13.0 

type HostName string

func HostNameProvider added in v1.13.0 

func HostNameProvider() (HostName, error)

type InstanceID added in v1.13.0 

type InstanceID string

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 NamespaceLogger added in v1.16.0 

type NamespaceLogger log.Logger

type RuntimeMetricsReporterParams added in v1.16.0 

type RuntimeMetricsReporterParams struct {
	fx.In

	MetricHandler metrics.Handler
	Logger        log.SnTaggedLogger
	InstanceID    InstanceID `optional:"true"`
}

type ServiceNames added in v1.16.0 

type ServiceNames map[primitives.ServiceName]struct{}

type ThrottledLoggerRpsFn added in v1.13.0 

type ThrottledLoggerRpsFn quotas.RateFn

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.