service

package
v0.10.1 Latest Latest
Warning

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

Go to latest
Published: Nov 21, 2019 License: MIT Imports: 24 Imported by: 19

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
	PProfInitializer    common.PProfInitializer
	PersistenceConfig   config.Persistence
	ClusterMetadata     cluster.Metadata
	ReplicatorConfig    config.Replicator
	MetricsClient       metrics.Client
	MessagingClient     messaging.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
}

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 {
	// Create vends a bootstrapped membership monitor
	Create(d *yarpc.Dispatcher) (membership.Monitor, error)
}

MembershipMonitorFactory provides a bootstrapped membership monitor

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() log.Logger

	GetThrottledLogger() log.Logger

	GetMetricsClient() metrics.Client

	GetClientBean() client.Bean

	GetTimeSource() clock.TimeSource

	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

	GetArchivalMetadata() archiver.ArchivalMetadata

	GetArchiverProvider() provider.ArchiverProvider

	GetPayloadSerializer() persistence.PayloadSerializer
}

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.

func NewTestService added in v0.3.11

func NewTestService(
	clusterMetadata cluster.Metadata,
	messagingClient messaging.Client,
	metrics metrics.Client,
	clientBean client.Bean,
	archivalMetadata archiver.ArchivalMetadata,
	archiverProvider provider.ArchiverProvider,
	serializer persistence.PayloadSerializer,
) Service

NewTestService is the new service instance created for testing

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL