registry

Documentation

Overview

Package registry is responsible for registering and unregistering services and servers.

Index

• Variables
• type Registry
  • func New(backend store.Backend, reg prometheus.Registerer, log *zap.SugaredLogger, ...) (*Registry, error)
  • func (r *Registry) ListNamespaces() (discovery.Namespaces, error)
  • func (r *Registry) ListServer(selector string) (discovery.Servers, error)
  • func (r *Registry) ListService(namespace, selector string) (discovery.Services, error)
  • func (r *Registry) ReRegisterAllServices() (numChanges int, err error)
  • func (r *Registry) RegisterNamespace(n discovery.Namespace) (*discovery.Namespace, error)
  • func (r *Registry) RegisterServer(name string, labels discovery.Labels) (*discovery.Server, error)
  • func (r *Registry) RegisterService(s discovery.Service) (*discovery.Service, error)
  • func (r Registry) StartCacheUpdater(ctx context.Context, reSyncInterval time.Duration)
  • func (r *Registry) UnRegisterNamespace(name string) error
  • func (r *Registry) UnRegisterServer(name string) error
  • func (r *Registry) UnRegisterService(idOrEndpoint, namespace string) error

Variables

var (
	ErrNotFound         = errors.New("not found")
	ErrContainsServices = errors.New("server has registered services")
)

Common errors

Types

type Registry

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

Registry registers server or service.

func New

func New(backend store.Backend, reg prometheus.Registerer, log *zap.SugaredLogger, numReplicas int) (*Registry, error)

New creates a new registry.

func (*Registry) ListNamespaces

func (r *Registry) ListNamespaces() (discovery.Namespaces, error)

ListNamespaces lists all services.

func (*Registry) ListServer

func (r *Registry) ListServer(selector string) (discovery.Servers, error)

ListServer lists servers by selector.

func (*Registry) ListService

func (r *Registry) ListService(namespace, selector string) (discovery.Services, error)

ListService lists all services.

func (*Registry) ReRegisterAllServices

func (r *Registry) ReRegisterAllServices() (numChanges int, err error)

ReRegisterAllServices reregisters all services.

func (*Registry) RegisterNamespace

func (r *Registry) RegisterNamespace(n discovery.Namespace) (*discovery.Namespace, error)

RegisterNamespace registers a namespace.

func (*Registry) RegisterServer

func (r *Registry) RegisterServer(name string, labels discovery.Labels) (*discovery.Server, error)

RegisterServer registers a server.

func (*Registry) RegisterService

func (r *Registry) RegisterService(s discovery.Service) (*discovery.Service, error)

RegisterService registers a service.

func (Registry) StartCacheUpdater

func (r Registry) StartCacheUpdater(ctx context.Context, reSyncInterval time.Duration)

StartCacheUpdater starts a namespace cache updater. It resyncs cache all reSyncInterval.

func (*Registry) UnRegisterNamespace

func (r *Registry) UnRegisterNamespace(name string) error

UnRegisterNamespace unregisters a namespace.

func (*Registry) UnRegisterServer

func (r *Registry) UnRegisterServer(name string) error

UnRegisterServer unregisters a server.

func (*Registry) UnRegisterService

func (r *Registry) UnRegisterService(idOrEndpoint, namespace string) error

UnRegisterService removes a service by id or endpoint. If namespace is empty string then discovery.DefaultNamespace is used.