resource

package
v1.36.1 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2026 License: MIT Imports: 47 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultOptions = fx.Options(
	fx.Provide(RPCFactoryProvider),
	fx.Provide(PerServiceDialOptionsProvider),
	fx.Provide(ArchivalMetadataProvider),
	fx.Provide(ArchiverProviderProvider),
	fx.Provide(ThrottledLoggerProvider),
	fx.Provide(SdkClientFactoryProvider),
	fx.Provide(DCRedirectionPolicyProvider),
)
View Source 
var Module = fx.Options(
	persistenceClient.Module,
	dynamicconfig.Module,
	serialization.Module,
	fx.Provide(HostNameProvider),
	fx.Provide(TimeSourceProvider),
	cluster.MetadataLifetimeHooksModule,
	fx.Provide(SearchAttributeMapperProviderProvider),
	fx.Provide(SearchAttributeProviderProvider),
	fx.Provide(SearchAttributeManagerProvider),
	fx.Provide(NamespaceRegistryProvider),
	nsregistry.RegistryLifetimeHooksModule,
	fx.Provide(fx.Annotate(
		func(p namespace.Registry) pingable.Pingable { return p },
		fx.ResultTags(`group:"deadlockDetectorRoots"`),
	)),
	fx.Provide(ClientFactoryProvider),
	fx.Provide(ClientBeanProvider),
	fx.Provide(FrontendClientProvider),
	fx.Provide(AdminClientProvider),
	fx.Provide(GrpcListenerProvider),
	fx.Provide(RuntimeMetricsReporterProvider),
	metrics.RuntimeMetricsReporterLifetimeHooksModule,
	fx.Provide(HistoryRawClientProvider),
	fx.Provide(HistoryClientProvider),
	fx.Provide(MatchingRawClientProvider),
	fx.Provide(MatchingClientProvider),
	membership.GRPCResolverModule,
	fx.Provide(FrontendHTTPClientCacheProvider),
	fx.Provide(PersistenceConfigProvider),
	fx.Provide(health.NewServer),
	fx.Provide(namespace.NewDefaultReplicationResolverFactory),
	deadlock.Module,
	config.Module,
	testhooks.Module,
	fx.Provide(commonnexus.NewLoggedHTTPClientTraceProvider),
)

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

Functions

func AdminClientProvider 

func AdminClientProvider(clientBean client.Bean, clusterMetadata cluster.Metadata) (adminservice.AdminServiceClient, error)

func ArchivalMetadataProvider 

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

func ArchiverProviderProvider 

func ArchiverProviderProvider(
	cfg *config.Config,
	persistenceExecutionManager persistence.ExecutionManager,
	logger log.SnTaggedLogger,
	metricsHandler metrics.Handler,
) provider.ArchiverProvider

func ClientBeanProvider 

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

func ClientFactoryProvider 

func ClientFactoryProvider(
	factoryProvider client.FactoryProvider,
	rpcFactory common.RPCFactory,
	membershipMonitor membership.Monitor,
	metricsHandler metrics.Handler,
	dynamicCollection *dynamicconfig.Collection,
	testHooks testhooks.TestHooks,
	persistenceConfig *config.Persistence,
	logger log.SnTaggedLogger,
	throttledLogger log.ThrottledLogger,
) client.Factory

func DCRedirectionPolicyProvider 

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

func DefaultSnTaggedLoggerProvider 

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

func FrontendClientProvider 

func FrontendClientProvider(clientBean client.Bean) workflowservice.WorkflowServiceClient

func FrontendHTTPClientCacheProvider 

func FrontendHTTPClientCacheProvider(
	metadata cluster.Metadata,
	tlsConfigProvider encryption.TLSConfigProvider,
) *cluster.FrontendHTTPClientCache

func GrpcListenerProvider 

func GrpcListenerProvider(factory common.RPCFactory) net.Listener

func NamespaceRegistryProvider 

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

func PerServiceDialOptionsProvider 

func PerServiceDialOptionsProvider() map[primitives.ServiceName][]grpc.DialOption

func PersistenceConfigProvider 

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

func RPCFactoryProvider 

func RPCFactoryProvider(
	cfg *config.Config,
	svcName primitives.ServiceName,
	logger log.Logger,
	metricsHandler metrics.Handler,
	tlsConfigProvider encryption.TLSConfigProvider,
	resolver *membership.GRPCResolver,
	tracingStatsHandler telemetry.ClientStatsHandler,
	perServiceDialOptions map[primitives.ServiceName][]grpc.DialOption,
	monitor membership.Monitor,
	dc *dynamicconfig.Collection,
) (common.RPCFactory, error)

func RuntimeMetricsReporterProvider 

func RuntimeMetricsReporterProvider(
	params RuntimeMetricsReporterParams,
) *metrics.RuntimeMetricsReporter

func SdkClientFactoryProvider 

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 

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

func SearchAttributeMapperProviderProvider 

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

func SearchAttributeProviderProvider 

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

func SearchAttributeValidatorProvider 

func SearchAttributeValidatorProvider(
	saProvider searchattribute.Provider,
	saMapperProvider searchattribute.MapperProvider,
	visibilityMgr manager.VisibilityManager,
	dynamicCollection *dynamicconfig.Collection,
) *searchattribute.Validator

SearchAttributeValidatorProvider creates a new search attribute validator with the given dependencies. It configures the validator with dynamic config values for key limits, value size limits, total size limits, visibility allowlist, and system search attribute error suppression.

func ThrottledLoggerProvider 

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

func TimeSourceProvider 

func TimeSourceProvider() clock.TimeSource

Types

type HistoryClient 

type HistoryClient historyservice.HistoryServiceClient

func HistoryClientProvider 

func HistoryClientProvider(historyRawClient HistoryRawClient) HistoryClient

type HistoryRawClient 

type HistoryRawClient historyservice.HistoryServiceClient

func HistoryRawClientProvider 

func HistoryRawClientProvider(clientBean client.Bean) HistoryRawClient

type HostName 

type HostName string

func HostNameProvider 

func HostNameProvider() (HostName, error)

type InstanceID 

type InstanceID string

type MatchingClient 

type MatchingClient matchingservice.MatchingServiceClient

func MatchingClientProvider 

func MatchingClientProvider(matchingRawClient MatchingRawClient) MatchingClient

type MatchingRawClient 

type MatchingRawClient matchingservice.MatchingServiceClient

func MatchingRawClientProvider 

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

type NamespaceLogger 

type NamespaceLogger log.Logger

type RuntimeMetricsReporterParams 

type RuntimeMetricsReporterParams struct {
	fx.In

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

type ServiceNames 

type ServiceNames map[primitives.ServiceName]struct{}

type ThrottledLoggerRpsFn 

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.