local

Documentation

Index

• type Registry
  • func New(authority string, entries ...*ServiceEntry) *Registry
  • func (r *Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) GetService(_ context.Context, name string) ([]*registry.ServiceInstance, error)
  • func (r *Registry) Register(_ context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) Watch(_ context.Context, name string) (registry.Watcher, error)
• type ServiceEntry
  • func NewServiceEntry(id, name, version string, endpoints ...string) *ServiceEntry

Types

type Registry

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

func New

func New(authority string, entries ...*ServiceEntry) *Registry

func (*Registry) Deregister

func (r *Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error

func (*Registry) GetService

func (r *Registry) GetService(_ context.Context, name string) ([]*registry.ServiceInstance, error)

func (*Registry) Register

func (r *Registry) Register(_ context.Context, service *registry.ServiceInstance) error

func (*Registry) Watch

func (r *Registry) Watch(_ context.Context, name string) (registry.Watcher, error)

type ServiceEntry

type ServiceEntry struct {
	ID        string
	Name      string
	Endpoints []string
	Version   string
}

func NewServiceEntry

func NewServiceEntry(id, name, version string, endpoints ...string) *ServiceEntry