discovery

Documentation

Index

• type Discovery
• type Registry
  • func New(config *api.Config) (_ *Registry, err error)
  • func (t *Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error
  • func (t *Registry) GetService(ctx context.Context, filter string) (out []*registry.ServiceInstance, err error)
  • func (t *Registry) Register(_ context.Context, service *registry.ServiceInstance) error
  • func (t *Registry) Watch(ctx context.Context, filter string) (registry.Watcher, error)

Types

type Discovery

type Discovery interface {
	GetService(ctx context.Context, filter string) ([]*registry.ServiceInstance, error)
	Watch(ctx context.Context, filter string) (registry.Watcher, error)
}

type Registry

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

func New

func New(config *api.Config) (_ *Registry, err error)

func (*Registry) Deregister

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

func (*Registry) GetService

func (t *Registry) GetService(ctx context.Context, filter string) (out []*registry.ServiceInstance, err error)

func (*Registry) Register

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

func (*Registry) Watch

func (t *Registry) Watch(ctx context.Context, filter string) (registry.Watcher, error)