Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMetricsServiceIdx ¶ added in v0.5.0
func GetMetricsServiceIdx(serviceName string, logger log.Logger) metrics.ServiceIdx
GetMetricsServiceIdx returns the metrics name
Types ¶
type BootstrapParams ¶
type BootstrapParams struct { Name string InstanceID string Logger log.Logger ThrottledLogger log.Logger MetricScope tally.Scope MembershipFactory MembershipMonitorFactory RPCFactory common.RPCFactory AbstractDatastoreFactory persistenceClient.AbstractDataStoreFactory PProfInitializer common.PProfInitializer PersistenceConfig config.Persistence ClusterMetadata cluster.Metadata ReplicatorConfig config.Replicator MetricsClient metrics.Client MessagingClient messaging.Client BlobstoreClient blobstore.Client ESClient es.Client ESConfig *es.Config DynamicConfig dynamicconfig.Client DispatcherProvider client.DispatcherProvider DCRedirectionPolicy config.DCRedirectionPolicy PublicClient workflowserviceclient.Interface ArchivalMetadata archiver.ArchivalMetadata ArchiverProvider provider.ArchiverProvider Authorizer authorization.Authorizer }
BootstrapParams holds the set of parameters needed to bootstrap a service
func (*BootstrapParams) UpdateLoggerWithServiceName ¶ added in v0.4.0
func (params *BootstrapParams) UpdateLoggerWithServiceName(name string)
UpdateLoggerWithServiceName tag logging with service name from the top level
type MembershipMonitorFactory ¶ added in v0.5.7
type MembershipMonitorFactory interface { // GetMembershipMonitor return a membership monitor GetMembershipMonitor() (membership.Monitor, error) }
MembershipMonitorFactory provides a bootstrapped membership monitor
type Service ¶
type Service interface { GetHostName() string Start() Stop() GetLogger() log.Logger GetThrottledLogger() log.Logger GetMetricsClient() metrics.Client GetClientBean() client.Bean GetTimeSource() clock.TimeSource GetDispatcher() *yarpc.Dispatcher GetMembershipMonitor() membership.Monitor GetHostInfo() *membership.HostInfo GetClusterMetadata() cluster.Metadata GetMessagingClient() messaging.Client GetBlobstoreClient() blobstore.Client GetArchivalMetadata() archiver.ArchivalMetadata GetArchiverProvider() provider.ArchiverProvider GetPayloadSerializer() persistence.PayloadSerializer }
Service is the interface which must be implemented by all the services TODO: Service contains many methods that are not used now that we have resource bean, these should be cleaned up
func New ¶
func New(params *BootstrapParams) Service
New instantiates a Service Instance TODO: have a better name for Service.
Directories ¶
Path | Synopsis |
---|---|
Package dynamicconfig is a generated GoMock package.
|
Package dynamicconfig is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.