discovery

Documentation

Index

• type Builder
  • func NewBuilder(dis registry.Discovery) *Builder
  • func (b *Builder) Build(target *url.URL) (cli.ServiceDiscovery, error)
  • func (b *Builder) Scheme() string
• type Resolver
  • func (r *Resolver) Clone(servicePath string) (cli.ServiceDiscovery, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) GetServices() []*cli.KVPair
  • func (r *Resolver) RemoveWatcher(ch chan []*cli.KVPair)
  • func (r *Resolver) SetFilter(filter cli.ServiceDiscoveryFilter)
  • func (r *Resolver) WatchService() chan []*cli.KVPair

Types

type Builder

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

func NewBuilder

func NewBuilder(dis registry.Discovery) *Builder

func (*Builder) Build

func (b *Builder) Build(target *url.URL) (cli.ServiceDiscovery, error)

func (*Builder) Scheme

func (b *Builder) Scheme() string

type Resolver

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

func (*Resolver) Clone

func (r *Resolver) Clone(servicePath string) (cli.ServiceDiscovery, error)

Clone clone a new resolver

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) GetServices

func (r *Resolver) GetServices() []*cli.KVPair

GetServices returns the servers

func (*Resolver) RemoveWatcher

func (r *Resolver) RemoveWatcher(ch chan []*cli.KVPair)

RemoveWatcher remove a non-nil chan.

func (*Resolver) SetFilter

func (r *Resolver) SetFilter(filter cli.ServiceDiscoveryFilter)

func (*Resolver) WatchService

func (r *Resolver) WatchService() chan []*cli.KVPair

WatchService returns a nil chan.