registry

May 19, 2021

Changes in this version

+ var ErrValidation = errors.New("validation error")

+ func IsNamespaceNotFound(err error) bool

+ func IsServersNotFound(err error) bool

+ func IsValidationError(err error) bool

May 18, 2021

Changes in this version

+ var ErrNamespaceNotFound = errors.New("namespace not found")

+ var ErrNoServersFound = errors.New("no servers found")

May 18, 2021

Changes in this version

type Registry

+ func (r Registry) StartServiceCounterUpdater(ctx context.Context, interval time.Duration)

Feb 19, 2021

Changes in this version

type Registry

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

Feb 3, 2021

Changes in this version

+ var ErrContainsServices = errors.New("server has registered services")

+ var ErrNotFound = errors.New("not found")

+ type Registry struct

+ 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) UnRegisterNamespace(name string) error

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

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