Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BootstrapParams ¶
type BootstrapParams struct {
Name string
Logger bark.Logger
MetricScope tally.Scope
RingpopFactory RingpopFactory
RPCFactory common.RPCFactory
PProfInitializer common.PProfInitializer
PersistenceConfig config.Persistence
ClusterMetadata cluster.Metadata
ReplicatorConfig config.Replicator
MessagingClient messaging.Client
DynamicConfig dynamicconfig.Client
}
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 RingpopFactory ¶
type RingpopFactory interface {
// CreateRingpop vends a bootstrapped ringpop object
CreateRingpop(d *yarpc.Dispatcher) (*ringpop.Ringpop, error)
}
RingpopFactory provides a bootstrapped ringpop
type Service ¶
type Service interface {
// GetHostName returns the name of host running the service
GetHostName() string
// Start the service
Start()
// Stop stops the service
Stop()
GetLogger() bark.Logger
GetMetricsClient() metrics.Client
GetClientFactory() client.Factory
GetDispatcher() *yarpc.Dispatcher
GetMembershipMonitor() membership.Monitor
GetHostInfo() *membership.HostInfo
// GetClusterMetadata returns the service cluster metadata
GetClusterMetadata() cluster.Metadata
// GetMessagingClient returns the messaging client against Kafka
GetMessagingClient() messaging.Client
}
Service is the interface which must be implemented by all the services
func New ¶
func New(params *BootstrapParams) Service
New instantiates a Service Instance TODO: have a better name for Service.
Click to show internal directories.
Click to hide internal directories.