registry

type Option ¶

type Option interface {
	// contains filtered or unexported methods
}

func WithListener(ln net.Listener) Option

func WithLogger(logger *zap.Logger) Option

func WithPromRegistry(promRegistry *prometheus.Registry) Option

type Service ¶

type Service struct {
	// contains filtered or unexported fields
}

Service manages the registry service, which provides a server for nodes to register and discovery the cluster.

func NewService(conf *config.Config, opts ...Option) *Service

func (s *Service) Cluster() *cluster.Cluster

func (s *Service) GracefulStop()

func (s *Service) Start() error

func (s *Service) Stop()