Documentation
¶
Index ¶
- Variables
- func ArchivalMetadataProvider(dc *dynamicconfig.Collection, cfg *config.Config) archiver.ArchivalMetadata
- func ArchiverProviderProvider(cfg *config.Config) provider.ArchiverProvider
- func ClientBeanProvider(clientFactory client.Factory, clusterMetadata cluster.Metadata) (client.Bean, error)
- func ClientFactoryProvider(factoryProvider client.FactoryProvider, rpcFactory common.RPCFactory, ...) client.Factory
- func DCRedirectionPolicyProvider(cfg *config.Config) config.DCRedirectionPolicy
- func DefaultSnTaggedLoggerProvider(logger log.Logger, sn primitives.ServiceName) log.SnTaggedLogger
- func FrontendClientProvider(clientBean client.Bean) workflowservice.WorkflowServiceClient
- func GrpcListenerProvider(factory common.RPCFactory) net.Listener
- func HistoryBootstrapContainerProvider(logger log.SnTaggedLogger, metricsHandler metrics.Handler, ...) *archiver.HistoryBootstrapContainer
- func HistoryClientProvider(clientBean client.Bean) historyservice.HistoryServiceClient
- func NamespaceRegistryProvider(logger log.SnTaggedLogger, metricsHandler metrics.Handler, ...) namespace.Registry
- func PersistenceConfigProvider(persistenceConfig config.Persistence, dc *dynamicconfig.Collection) *config.Persistence
- func RPCFactoryProvider(cfg *config.Config, svcName primitives.ServiceName, logger log.Logger, ...) (common.RPCFactory, error)
- func RegisterBootstrapContainer(archiverProvider provider.ArchiverProvider, serviceName primitives.ServiceName, ...) error
- func RuntimeMetricsReporterProvider(params RuntimeMetricsReporterParams) *metrics.RuntimeMetricsReporter
- func SdkClientFactoryProvider(cfg *config.Config, tlsConfigProvider encryption.TLSConfigProvider, ...) (sdk.ClientFactory, error)
- func SearchAttributeManagerProvider(timeSource clock.TimeSource, cmMgr persistence.ClusterMetadataManager, ...) searchattribute.Manager
- func SearchAttributeMapperProviderProvider(saMapper searchattribute.Mapper, namespaceRegistry namespace.Registry, ...) searchattribute.MapperProvider
- func SearchAttributeProviderProvider(timeSource clock.TimeSource, cmMgr persistence.ClusterMetadataManager, ...) searchattribute.Provider
- func ThrottledLoggerProvider(logger log.SnTaggedLogger, fn ThrottledLoggerRpsFn) log.ThrottledLogger
- func TimeSourceProvider() clock.TimeSource
- func VisibilityBootstrapContainerProvider(logger log.SnTaggedLogger, metricsHandler metrics.Handler, ...) *archiver.VisibilityBootstrapContainer
- type HostName
- type InstanceID
- type MatchingClient
- type MatchingRawClient
- type NamespaceLogger
- type RuntimeMetricsReporterParams
- type ServiceNames
- type ThrottledLoggerRpsFn
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(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 HistoryClientProvider ¶ added in v1.14.0
func HistoryClientProvider(clientBean client.Bean) historyservice.HistoryServiceClient
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 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
Click to show internal directories.
Click to hide internal directories.